diff --git a/dags/OSV.py b/dags/OSV.py
index 97b2771..ce54402 100644
--- a/dags/OSV.py
+++ b/dags/OSV.py
@@ -52,6 +52,7 @@ def read_data_1C(**kwargs):
 
     data_from_1c = response.json()
     df = pd.DataFrame(data_from_1c['data'])
+    engine = get_db_engine()
     table_name = 'oborotno_salbdovaya_vedomostb'
 
     with engine.begin() as conn: