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

dags/pogasheniya.py

@@ -64,6 +64,7 @@ def pogasheniya(**kwargs):
             conn.execute("""
             INSERT INTO public.pogasheniya (schet, uid_dogovor, name, nomer, date_begin, date_end)
             SELECT * FROM temp_pogasheniya
+            DO UPDATE SET
             ON CONFLICT (schet, uid_dogovor, nomer)
                 name = EXCLUDED.name,
                 agreement_num = EXCLUDED.agreement_num,