Peter Mutwiri commited on
Commit ·
59ed5ec
1
Parent(s): df4b0a2
fixed indentation issue
Browse files
app/routers/datasources.py
CHANGED
|
@@ -92,16 +92,16 @@ async def create_source_json(
|
|
| 92 |
# Try QStash if available
|
| 93 |
if is_qstash_available():
|
| 94 |
try:
|
| 95 |
-
|
| 96 |
-
|
| 97 |
-
|
| 98 |
-
|
| 99 |
-
|
| 100 |
-
|
| 101 |
-
|
| 102 |
except Exception as e:
|
| 103 |
-
|
| 104 |
-
|
| 105 |
else:
|
| 106 |
# ✅ Fallback: Direct Redis publish
|
| 107 |
redis.publish(f"analytics_trigger:{org_id}:{source_id}", json.dumps(trigger_data))
|
|
|
|
| 92 |
# Try QStash if available
|
| 93 |
if is_qstash_available():
|
| 94 |
try:
|
| 95 |
+
from app.qstash_client import get_qstash_client
|
| 96 |
+
client = get_qstash_client()
|
| 97 |
+
result = client.message.publish(
|
| 98 |
+
url=f"{APP_URL}/api/v1/analytics/callback",
|
| 99 |
+
body=trigger_data
|
| 100 |
+
)
|
| 101 |
+
logger.info(f"📤 QStash queued: {result.message_id}")
|
| 102 |
except Exception as e:
|
| 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))
|