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

dags/pogasheniya.py

@@ -34,7 +34,7 @@ def get_db_engine():
 def pogasheniya(**kwargs):
     engine = get_db_engine()
     query = """
-    SELECT DISTINCT
+    SELECT
           osv.schet
         , osv.uid_subkonto2 uid_dogovor
         , osv.subkonto2 name
@@ -43,7 +43,7 @@ def pogasheniya(**kwargs):
         , osv.date_end
     FROM oborotno_salbdovaya_vedomostb osv
     LEFT JOIN pogasheniya p on p.uid_dogovor = osv.uid_subkonto2 and p.schet = osv.schet
-    WHERE p.uid_dogovor is null
+    WHERE p.uid_dogovor is null and osv.schet::text ~~ '%03%'::text OR osv.schet::text ~~ '%01%'::text
     UNION ALL
     SELECT 
           '76.07.1' schet