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

2025-12-02 14:16:01 +00:00 · 2025-12-02 14:16:01 +00:00 · a312c9e5ff
parent cb2b15405b
commit a312c9e5ff
1 changed files with 2 additions and 1 deletions
--- 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,