diff --git a/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala b/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala
index 729cb95d0..bebe71f64 100644
--- a/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala
+++ b/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala
@@ -492,7 +492,7 @@ object ExternalDataSources {
       }
   }
 
-  def magicRecsNotficationOpenOrClickEventsSource(
+  def magicRecsNotificationOpenOrClickEventsSource(
     implicit dateRange: DateRange
   ): TypedPipe[MagicRecsNotificationLite] = {
     DAL
diff --git a/src/scala/com/twitter/simclusters_v2/scalding/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraph.scala b/src/scala/com/twitter/simclusters_v2/scalding/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraph.scala
index 5e289c6b8..848a9db08 100644
--- a/src/scala/com/twitter/simclusters_v2/scalding/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraph.scala
+++ b/src/scala/com/twitter/simclusters_v2/scalding/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraph.scala
@@ -491,7 +491,7 @@ object AssembleMultiTypeGraph {
 
     // user-MRNotifOpenOrClick events from last 7 days
     val userMRNotifOpenOrClickEvents: TypedPipe[MagicRecsNotificationLite] =
-      ExternalDataSources.magicRecsNotficationOpenOrClickEventsSource(dateRange =
+      ExternalDataSources.magicRecsNotificationOpenOrClickEventsSource(dateRange =
         DateRange(dateRange.end - Days(7), dateRange.end))
 
     // user-searchQuery strings from last 7 days
diff --git a/src/scala/com/twitter/simclusters_v2/scio/common/ExternalDataSources.scala b/src/scala/com/twitter/simclusters_v2/scio/common/ExternalDataSources.scala
index ed9e1aa2d..01246099d 100644
--- a/src/scala/com/twitter/simclusters_v2/scio/common/ExternalDataSources.scala
+++ b/src/scala/com/twitter/simclusters_v2/scio/common/ExternalDataSources.scala
@@ -236,13 +236,13 @@ object ExternalDataSources {
       }
   }
 
-  def magicRecsNotficationOpenOrClickEventsSource(
+  def magicRecsNotificationOpenOrClickEventsSource(
     interval: Interval
   )(
     implicit sc: ScioContext
   ): SCollection[MagicRecsNotificationLite] = {
     sc.customInput(
-        "ReadMagicRecsNotficationOpenOrClickEventsSource",
+        "ReadMagicRecsNotificationOpenOrClickEventsSource",
         DAL
           .read(MagicrecsNotificationLite1DayLagScalaDataset, interval, DAL.Environment.Prod))
       .filter { entry =>
diff --git a/src/scala/com/twitter/simclusters_v2/scio/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraphScioBaseApp.scala b/src/scala/com/twitter/simclusters_v2/scio/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraphScioBaseApp.scala
index 18325e2fc..07f5b300b 100644
--- a/src/scala/com/twitter/simclusters_v2/scio/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraphScioBaseApp.scala
+++ b/src/scala/com/twitter/simclusters_v2/scio/multi_type_graph/assemble_multi_type_graph/AssembleMultiTypeGraphScioBaseApp.scala
@@ -423,7 +423,7 @@ trait AssembleMultiTypeGraphScioBaseApp extends ScioBeamJob[DateRangeOptions] {
 
     // user-MRNotifOpenOrClick events from last 7 days
     val userMRNotifOpenOrClickEvents =
-      ExternalDataSources.magicRecsNotficationOpenOrClickEventsSource(interval_7days)
+      ExternalDataSources.magicRecsNotificationOpenOrClickEventsSource(interval_7days)
 
     // user-searchQuery strings from last 7 days
     val userSearchQueryEdges =