🏴‍☠️ Overview

Adds a community source spec for n8n — the leading extensible workflow automation platform.

This source allows agents and developers to query their automation platform like a database, enabling powerful cross-source JOINs (e.g., correlating failed n8n workflows with PagerDuty incidents or GitHub deployments).

🗄️ Tables Implemented

• workflows — Automation workflows with tags, node count, and active status.
• executions — Execution runs with mode, finished status, and timing.
• tags — Workflow categorization tags.
• variables — Instance variables (Note: requires paid n8n license).

🛠️ Functions

• executions_by_workflow(workflow_id, status) — Native search function for scoped execution lookups.

🚀 Advanced Features Showcased

• Cursor Pagination: Implemented cursor_query with nextCursor response path.
• API Key Auth: Configured via X-N8N-API-KEY header.
• Configurable Base URL: Supports both self-hosted (http://localhost:5678/api/v1) and n8n Cloud (https://<account>.n8n.cloud/api/v1).
• Timestamp Formatting: Converts iso8601 to Coral Timestamp.
• Nested Field Flattening: Extracted nested project IDs (homeProject__id).
• Array Joining: Used join_array_path to flatten workflow tags into a comma-separated string.

💻 Demo Queries

1. List active workflows with their tags:

SELECT name, tag_names, node_count, updated_at
FROM n8n.workflows
WHERE active = true
ORDER BY updated_at DESC;