Temp: add webhook URL debug task
This commit is contained in:
@@ -152,11 +152,11 @@ class CallbackModule(CallbackBase):
|
||||
elapsed_seconds = int(completed_at - self.started_at)
|
||||
|
||||
# Get config from environment (set via Semaphore Variable Groups)
|
||||
webhook_url = os.environ.get('N8N_WEBHOOK_URL', '')
|
||||
client_id = os.environ.get('CLIENT_ID', 'UNKNOWN')
|
||||
client_name = os.environ.get('CLIENT_NAME', 'Unknown Client')
|
||||
billing_model = os.environ.get('BILLING_MODEL', 'hybrid')
|
||||
human_estimate = int(os.environ.get('HUMAN_ESTIMATE_SECONDS', 2700))
|
||||
webhook_url = self.play_vars.get("N8N_WEBHOOK_URL", os.environ.get("N8N_WEBHOOK_URL", ""))
|
||||
client_id = self.play_vars.get("CLIENT_ID", os.environ.get("CLIENT_ID", "UNKNOWN"))
|
||||
client_name = self.play_vars.get("CLIENT_NAME", os.environ.get("CLIENT_NAME", "Unknown Client"))
|
||||
billing_model = self.play_vars.get("BILLING_MODEL", os.environ.get("BILLING_MODEL", "hybrid"))
|
||||
human_estimate = int(self.play_vars.get("HUMAN_ESTIMATE_SECONDS", os.environ.get("HUMAN_ESTIMATE_SECONDS", 2700)))
|
||||
|
||||
# Determine overall status
|
||||
hosts_ok = stats.processed
|
||||
@@ -233,3 +233,4 @@ class CallbackModule(CallbackBase):
|
||||
except Exception as e:
|
||||
self._display.warning(f'Failed to post to n8n webhook: {str(e)}')
|
||||
self._display.warning(f'Payload was: {json.dumps(payload, indent=2)}')
|
||||
# patched - see v2_playbook_on_play_start for var reading
|
||||
|
||||
Reference in New Issue
Block a user