diff --git a/dags/fin_porfel.py b/dags/fin_porfel.py index 43f8ef7..66f4d48 100644 --- a/dags/fin_porfel.py +++ b/dags/fin_porfel.py @@ -56,7 +56,7 @@ def upsert_list_fin_portfel(**kwargs): conn.execute (""" INSERT INTO public.fin_porfel - SELECT + SELECT distinct schet , subkonto2 , summa_dogovora