Обновить dags/OSV.py

2025-09-03 09:28:47 +00:00 · 2025-09-03 09:28:47 +00:00 · ad448bebd2
parent e471647916
commit ad448bebd2
1 changed files with 1 additions and 1 deletions
--- a/dags/OSV.py
+++ b/dags/OSV.py
@ -133,7 +133,7 @@ def read_data_1C(**kwargs):
                index=False,
                method='multi'
            )
-            conn.execute(f"DELETE FROM public.{table_name} where get_date in (select distinct get_date from temp_{table_name})")
+            conn.execute(f"DELETE FROM public.{table_name} where get_date = CURRENT_DATE::date::timestamp")
            conn.execute(f"""
            INSERT INTO public.{table_name}
            SELECT