Update data_ingestion

data_ingestion

@@ -0,0 +1,9 @@
+def data_ingestion(data_file):
+    try:
+        df = pd.read_csv(data_file)  # This works better with Hugging Face file-like objects
+        data_pipelines["data_ingestion"] = df
+        log_event("Data ingestion completed successfully.")
+        return df.head()
+    except Exception as e:
+        log_event(f"Data ingestion failed: {str(e)}")
+        return f"Error: {str(e)}"