diff --git a/dags/pogasheniya.py b/dags/pogasheniya.py
index 43fbfda..8ff21c4 100644
--- a/dags/pogasheniya.py
+++ b/dags/pogasheniya.py
@@ -4,7 +4,7 @@ import pandas as pd
 import numpy as np
 from datetime import datetime
 from requests.auth import HTTPBasicAuth
-from sqlalchemy import create_engine
+from sqlalchemy import create_engine, text
 from airflow import DAG
 from airflow.operators.python import PythonOperator