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

dags/pogasheniya.py

@@ -33,7 +33,7 @@ def get_db_engine():
 
 def pogasheniya(**kwargs):
     engine = get_db_engine()
-    query = """
+    query = text("""
     SELECT
           osv.schet
         , osv.uid_subkonto2 as uid_dogovor
@@ -55,7 +55,7 @@ def pogasheniya(**kwargs):
     FROM lizingi_garantii osv
     LEFT JOIN pogasheniya p on p.nomer = osv.agreement_num
     WHERE p.uid_dogovor is null
-    """
+    """)
     df = pd.read_sql(query, engine)
     with engine.begin() as conn:
         if not df.empty: