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

dags/OSV_with_docs.py

@@ -331,18 +331,18 @@ def pogasheniya(**kwargs):
                 date_begin = EXCLUDED.date_begin,
                 date_end = EXCLUDED.date_end
             """)
-            # conn.execute("""
+            conn.execute("""
-            # UPDATE public.pogasheniya fp
+            UPDATE public.pogasheniya fp
-            # SET id = subquery.new_id
+            SET id = subquery.new_id
-            # FROM (
+            FROM (
-            #     SELECT 
+                SELECT 
-            #         id,
+                    id,
-            #         ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id
+                    ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id
-            #     FROM public.pogasheniya
+                FROM public.pogasheniya
-            # ) AS subquery
+            ) AS subquery
-            # WHERE fp.id = subquery.id;
+            WHERE fp.id = subquery.id;
-            # """
+            """
-            # )
+            )
             return 'Список обновлен.'
         else:
             return 'Обновлять нечего.'