Peter Mutwiri commited on
Commit ·
7279bde
1
Parent(s): 59ed5ec
fixed indentation issues
Browse files
app/routers/datasources.py
CHANGED
|
@@ -103,13 +103,13 @@ async def create_source_json(
|
|
| 103 |
logger.warning(f"⚠️ QStash failed, using Redis: {e}")
|
| 104 |
redis.publish(f"analytics_trigger:{org_id}:{source_id}", json.dumps(trigger_data))
|
| 105 |
else:
|
| 106 |
-
|
| 107 |
-
|
| 108 |
-
|
| 109 |
|
| 110 |
except Exception as e:
|
| 111 |
-
|
| 112 |
-
|
| 113 |
# 4. 📡 Broadcast to connected dashboards
|
| 114 |
await sio.emit(
|
| 115 |
"datasource:new-rows",
|
|
|
|
| 103 |
logger.warning(f"⚠️ QStash failed, using Redis: {e}")
|
| 104 |
redis.publish(f"analytics_trigger:{org_id}:{source_id}", json.dumps(trigger_data))
|
| 105 |
else:
|
| 106 |
+
# ✅ Fallback: Direct Redis publish
|
| 107 |
+
redis.publish(f"analytics_trigger:{org_id}:{source_id}", json.dumps(trigger_data))
|
| 108 |
+
logger.info("📡 Redis fallback for analytics trigger")
|
| 109 |
|
| 110 |
except Exception as e:
|
| 111 |
+
logger.warning(f"⚠️ Analytics trigger failed (non-critical): {e}")
|
| 112 |
+
# ✅ DON'T raise - ingestion should succeed even if analytics fails
|
| 113 |
# 4. 📡 Broadcast to connected dashboards
|
| 114 |
await sio.emit(
|
| 115 |
"datasource:new-rows",
|