Spaces:

petermutwiri
/

analytics-engine

Paused

Peter Mutwiri commited on Nov 20, 2025

Commit

84ca561

1 Parent(s): aab8f97

corrected source id and org id

Files changed (1) hide show

app/routers/datasources.py CHANGED Viewed

@@ -120,7 +120,7 @@ async def create_source_json(
         }
         redis.lpush("python:task_queue", json.dumps(task))
-        df, industry, confidence = canonify_df(orgId, f"{sourceId}.json")
         # 3. 🎯 Prepare preview for real-time broadcast
         # Convert DataFrame to JSON-safe format

         }
         redis.lpush("python:task_queue", json.dumps(task))
+        df, industry, confidence = canonify_df(org_id, source_id)
         # 3. 🎯 Prepare preview for real-time broadcast
         # Convert DataFrame to JSON-safe format