Webhook-based pipeline failure intake and forwarding router

How it works

1. 1.Receive a POST request on the webhook path data-engineering-pipeline-failure-intake-router-intake with responseMode set to responseNode.
2. 2.Normalize Input (Set node) copies the request body into an input field and adds a static source value.
3. 3.Validate Input (If node) checks that the input string is not empty.
4. 4.On the true branch, Forward To Service sends a POST with a placeholder body parameter and genericCredentialType authentication.
5. 5.Respond Success returns {"status":"accepted"} after forwarding; Respond Invalid returns {"status":"invalid"} on the false branch.

Use cases

• Central intake endpoint for data engineering pipeline failure notifications before routing them to an external system.
• Early rejection of empty or malformed payloads with an explicit invalid response.

Requirements

• Activate the workflow so the webhook endpoint becomes reachable.
• Configure genericCredentialType credentials for the HTTP Request node and replace the placeholder URL api.example.com.
• Replace the REPLACE_WITH_YOUR_VALUE placeholder in the request body with the real payload value.

Setup and testing in n8n

1. POST a non-empty body to the webhook path and confirm an accepted response.
2. POST an empty body and confirm an invalid response with no outbound request.
3. Inspect the execution log to verify which validation branch ran and whether the HTTP call succeeded.

Service Value

Ready-made workflow template for automation delivery and service execution.