diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py
index f3bdfd1..652c5aa 100644
--- a/dags/pogasheniya.py
+++ b/dags/pogasheniya.py
@@ -64,8 +64,8 @@ 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)
+            DO UPDATE SET
                 name = EXCLUDED.name,
                 agreement_num = EXCLUDED.agreement_num,
                 agreement_date = EXCLUDED.agreement_date,