atualiza filtro data

prefeitura-rio · Oct 11, 2023 · c9d8f21 · c9d8f21
1 parent 82f54e6
commit c9d8f21
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/pipelines/rj_smtr/tasks.py b/pipelines/rj_smtr/tasks.py
@@ -989,10 +989,17 @@ def get_recapture_timestamps(
     dates = dates.strftime("%Y-%m-%d").to_list()
 
     for date in dates:
-        datetime_filter = datetime.now(tz=timezone(constants.TIMEZONE.value)).replace(
+        datetime_filter = datetime.fromisoformat(f"{date} 23:59:00").replace(
             second=0, microsecond=0
         )
 
+        # Round down to the nearest interval_minutes minutes
+        datetime_filter = datetime_filter.replace(
+            minute=(datetime_filter.minute // interval_minutes) * interval_minutes
+        )
+
+        datetime_filter = datetime_filter.strftime("%Y-%m-%d %H:%M:%S")
+
         if datetime_filter > current_timestamp:
             flag_break = True