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

dags/OSV.py

@@ -51,8 +51,10 @@ def read_data_1C(**kwargs):
     )
 
     data_from_1c = response.json()
-    # df = pd.DataFrame(data_from_1c['data'])
-    return data_from_1c['data']
+    df = pd.DataFrame()
+    for data in data_from_1c['data']:
+        df.loc[len(df)] = data
+    return df
 
 with DAG(
     dag_id='data_download_from_1C_source',