Peter Mutwiri commited on
Commit ·
df4b0a2
1
Parent(s): 50fc282
fixed indentation issue
Browse files
app/routers/datasources.py
CHANGED
|
@@ -97,8 +97,8 @@ async def create_source_json(
|
|
| 97 |
result = client.message.publish(
|
| 98 |
url=f"{APP_URL}/api/v1/analytics/callback",
|
| 99 |
body=trigger_data
|
| 100 |
-
|
| 101 |
-
|
| 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))
|
|
|
|
| 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))
|