diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py index 9942d2e..abac92b 100644 --- a/dags/OSV_with_docs.py +++ b/dags/OSV_with_docs.py @@ -324,8 +324,9 @@ def pogasheniya(**kwargs): conn.execute(""" INSERT INTO public.pogasheniya (schet, uid_dogovor, name, nomer, date_begin, date_end) SELECT * FROM temp_pogasheniya - ON CONFLICT (schet, uid_dogovor, nomer) + ON CONFLICT (schet, uid_dogovor) DO UPDATE SET + nomer = EXCLUDED.nomer, name = EXCLUDED.name, nomer = EXCLUDED.nomer, date_begin = EXCLUDED.date_begin,