diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py
index b5b4f8c..43fbfda 100644
--- a/dags/pogasheniya.py
+++ b/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: