diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py
index 3c2326f..f3bdfd1 100644
--- a/dags/pogasheniya.py
+++ b/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,