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

dags/OSV.py

@@ -121,7 +121,7 @@ def read_data_1C(**kwargs):
                 index=False,
                 method='multi'
             )
-            conn.execute(f"DELETE FROM public.{table_name} WHERE ")
+            conn.execute(f"DELETE FROM public.{table_name}")
             conn.execute(f"""
             INSERT INTO public.{table_name}
             SELECT * FROM temp_{table_name}