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

dags/upload_dicts.py

@@ -207,7 +207,8 @@ def take_organizaciya(**kwargs):
             # conn.execute(f"DELETE FROM public.{table_name}")
             conn.execute(f"""
             INSERT INTO public.{table_name} (name, inn, kpp, uid_organizaciya)
-            SELECT  
+            SELECT
+                row_number() over (order by uid_organizaciya) id,
                 name,
                 inn,
                 kpp,