User Events MCP Pipeline

id: user_events_mcp_pipeline
name: User Events MCP Pipeline
tasks:
- id: execute_query
  type: mcp
  tool_name: mcp__assistents-supabase__execute_sql
  retry_policy:
    max_attempts: 2
    initial_interval: 1
  deployment_id: assistents-supabase
  tool_arguments:
    query: ${query}
  timeout_seconds: 30
- id: process_results
  type: script
  script: "import json\nimport os\n\n# Get query results\nresults = os.environ.get('execute_query.result',\
    \ '[]')\ndata = json.loads(results) if results else []\n\n# Process and format\
    \ results\nsummary = {\n    \"query_executed\": \"${query}\",\n    \"result_count\"\
    : len(data),\n    \"top_event_types\": data[:5] if isinstance(data, list) else\
    \ [],\n    \"execution_time\": \"${execution.started_at}\"\n}\n\nprint(f\"__OUTPUTS__\
    \ {json.dumps(summary)}\")\n"
  depends_on:
  - execute_query
  timeout_seconds: 30
inputs:
- name: query
  type: string
  default: SELECT event_type, COUNT(*) as count FROM user_events GROUP BY event_type
    ORDER BY count DESC LIMIT 10
  description: SQL query to execute
outputs:
  summary:
    source: process_results
    description: Processed summary of results
  query_results:
    source: execute_query
    description: Raw query results
version: 1.0.0
description: Uses MCP to query user_events and analyze data