Fix filter_ready_to_publish

kolzchut · Jul 17, 2024 · 3d962f0 · 3d962f0
1 parent 6e829fe
commit 3d962f0
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/operators/manual_data_entry/external.py b/operators/manual_data_entry/external.py
@@ -12,11 +12,12 @@
 CHECKPOINT = 'external-mde'
 
 def filter_ready_to_publish(stats: Stats):
-    def func(row):
-        if row.get('Status') == 'בייצור':
-            return True
-        stats.increase('External Manual Data: Entry not ready to publish')
-        return False
+    def func(rows):
+        for row in rows:
+            if row.get('Status') == 'בייצור':
+                yield row
+            else:
+                stats.increase('External Manual Data: Entry not ready to publish')
     return func
 
 def fetch_google_spreadsheet(stats):