File upload issue

.gitignore

@@ -12,4 +12,7 @@ output/models/inconsistent_scaler.joblib
 .env
 __pycache__
 __pycache__/*
+output/*
+.idea/*
+
 

salary_analytics/api.py

@@ -298,8 +298,11 @@ async def get_file_if_csv(source: str, file: Optional[UploadFile] = File(None)):
 async def run_streaming_pipeline(
     source: str = "db",
     batch_size: int = 10000,
-    file: Optional[UploadFile] = Depends(get_file_if_csv)
+    UploadFile: str=''):
-):
+
+    file = None
+    if len(UploadFile) > 0 :
+        file : Optional[UploadFile] = Depends(get_file_if_csv)
     """
     Run the complete salary analytics pipeline in batches.
     
@@ -327,6 +330,8 @@ async def run_streaming_pipeline(
         responses = []
         batch_number = 0
 
+        print("Sal************************", source)
+
         def preprocess_chunk(chunk):
             """Preprocess a chunk of data with the same logic as DataLoader."""
             # Convert dates