diff --git a/application/worker.py b/application/worker.py index 8442e7f4..d0c4bec9 100755 --- a/application/worker.py +++ b/application/worker.py @@ -960,13 +960,17 @@ def agent_webhook_worker(self, agent_id, payload): result = run_agent_logic(agent_config, input_data) except Exception as e: logging.error(f"Error running agent logic: {e}", exc_info=True) - return {"status": "error", "error": str(e)} - finally: self.update_state(state="PROGRESS", meta={"current": 100}) logging.info( f"Webhook processed for agent {agent_id}", extra={"agent_id": agent_id} ) - return {"status": "success", "result": result} + return {"status": "error"} + + self.update_state(state="PROGRESS", meta={"current": 100}) + logging.info( + f"Webhook processed for agent {agent_id}", extra={"agent_id": agent_id} + ) + return {"status": "success", "result": result} def ingest_connector(