Обновить dags/OSV.py
This commit is contained in:
parent
5810bd8f18
commit
f90fa406c3
|
|
@ -136,7 +136,7 @@ def read_data_1C(**kwargs):
|
||||||
conn.execute(f"DELETE FROM public.{table_name}")
|
conn.execute(f"DELETE FROM public.{table_name}")
|
||||||
conn.execute(f"""
|
conn.execute(f"""
|
||||||
INSERT INTO public.{table_name}
|
INSERT INTO public.{table_name}
|
||||||
SELECT * FROM temp_{table_name}
|
SELECT *, CURRENT_DATE::date::timestamp FROM temp_{table_name}
|
||||||
--ON CONFLICT (schet, subkonto1, subkonto2, organizaciya)
|
--ON CONFLICT (schet, subkonto1, subkonto2, organizaciya)
|
||||||
"""
|
"""
|
||||||
)
|
)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue