Discard zero lat lon after normalization to ensure the lat lon fields…

… are present
GlobalFishingWatch · Aug 5, 2024 · 97c639a · 97c639a
1 parent 307872f
commit 97c639a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/packages/pipe-vms-ingestion/vms_ingestion/normalization/pipeline.py b/packages/pipe-vms-ingestion/vms_ingestion/normalization/pipeline.py
@@ -74,8 +74,8 @@ def __init__(self, options):
                 date_range=(self.start_date, self.end_date),
                 labels=self.labels,
             )
-            | "Discard Zero Lat and Lon" >> DiscardZeroLatLon()
             | "Normalize" >> FeedNormalizationFactory.get_normalization(feed=self.feed)
+            | "Discard Zero Lat and Lon" >> DiscardZeroLatLon()
             | "Deduplicate" >> DeduplicateMsgs()
             | PickOutputFields(fields=[f"{field}" for field in self.output_fields])
             | "Write Sink"