auth_status
ChatGPTConfirms OAuth identity and lists accessible workspaces.
Overview
Connect Claude to Supaflow to build, run, monitor, and troubleshoot data pipelines. Discover connectors and datasources, review source schemas, create and edit pipelines, manage schedules, and inspect job status and results. Move data across SaaS apps, databases, data warehouses, and data lakes, including ETL, ELT, dbt Core transformations, and reverse ETL workflows. Sign in with your Supaflow account and select an accessible workspace. Pipeline execution uses your configured Supaflow agents.
Tools
connectors_list
ChatGPTLists connector types, versions, and capabilities.
datasources_catalog
ChatGPTLists discovered objects. Set refresh=true to enqueue schema discovery before polling the returned job.
datasources_catalog_reset_status
ChatGPTReturns the restoration-aware maintenance status for a catalog-reset job. Poll until maintenance_active is false.
datasources_create
ChatGPTCreates a datasource from encrypted configs or by copying an accessible datasource server-side. Plaintext sensitive values are rejected.
datasources_delete
ChatGPTSoft-deletes a datasource and dependent projects and pipelines, matching the Supaflow UI. Obtain explicit user confirmation immediately before calling.
datasources_disable
ChatGPTSets a datasource to inactive.
datasources_edit
ChatGPTUpdates datasource metadata or encrypted config fields. Plaintext sensitive values are rejected.
datasources_enable
ChatGPTSets a datasource to active.
datasources_get
ChatGPTGets safe datasource metadata; credential configs are never returned.
datasources_init
ChatGPTReturns connector properties as structured JSON. Never send plaintext credentials through the AI client.
datasources_list
ChatGPTLists tenant-scoped datasource metadata without credential configs. Offset pages are fresh live views. For a shift-resistant full inventory traversal, set sort=id and pass the last returned ID as after_id until an empty page. This is not a database snapshot; concurrent inserts and deletes can affect the traversal.
datasources_refresh
ChatGPTEnqueues schema discovery and returns a job ID for polling.
datasources_reset_catalog
ChatGPTExceptional recovery action that rediscovers the source catalog while preserving pipelines and selections. It temporarily pauses affected pipeline activity and may change cursor, type, or schema behavior on the next run. Obtain explicit user confirmation immediately before calling.
datasources_test
ChatGPTEnqueues a live connection test and returns a job ID for polling.
docs
ChatGPTReturns the canonical Supaflow documentation URL for an optional topic.
jobs_cancel
ChatGPTCancels a queued, picked, or running job. Obtain explicit user confirmation immediately before calling.
jobs_get
ChatGPTGets safe job metadata and terminal per-object metrics.
jobs_list
ChatGPTLists jobs with optional status, type, and pipeline filters.
jobs_logs
ChatGPTReturns the control-plane job response; local agent filesystem logs remain unavailable.
jobs_status
ChatGPTReturns lightweight status for polling one job.
pipelines_create
ChatGPTCreates and activates a pipeline from structured config and object selections.
pipelines_create_from_plan
ChatGPTCreates a pipeline after explicit confirmation of a signed plan and object scope.
pipelines_delete
ChatGPTSoft-deletes a pipeline. Obtain explicit user confirmation immediately before calling.
pipelines_disable
ChatGPTSets a pipeline to inactive.
pipelines_edit
ChatGPTUpdates pipeline name, description, or configuration. The destination prefix and custom-prefix flag cannot change after the pipeline leaves draft state.
pipelines_enable
ChatGPTSets a pipeline to active.
pipelines_get
ChatGPTGets one tenant-scoped pipeline.
pipelines_init
ChatGPTReturns capability-aware structured defaults for a source and project.
pipelines_list
ChatGPTLists tenant-scoped pipeline metadata. Offset pages are fresh live views. For a shift-resistant full inventory traversal, set sort=id and pass the last returned ID as after_id until an empty page. This is not a database snapshot; concurrent inserts and deletes can affect the traversal.
pipelines_prepare_create
ChatGPTBuilds a signed, short-lived pipeline plan and returns the total available object count plus a possibly truncated preview for user review.
pipelines_schema_add
ChatGPTAdds one fully qualified object to a pipeline selection.
pipelines_schema_list
ChatGPTLists selected pipeline objects, optionally including all catalog objects and fields. Offsets address the full catalog. Advance offset by limit while has_more is true, even if objects is empty or shorter than limit.
pipelines_schema_select
ChatGPTUpdates saved selections for the supplied pipeline objects; omitted objects are unchanged. Can deselect objects and overwrite their saved field, primary-key, and cursor selections, affecting subsequent runs. Does not enqueue a run or directly delete source or destination data. Inspect the current selections and obtain explicit user confirmation of the changes immediately before calling.
pipelines_sync
ChatGPTEnqueues a pipeline run for a private or public Supaflow agent.
projects_create
ChatGPTCreates a project linked to an accessible destination datasource.
projects_delete
ChatGPTSoft-deletes a project and its pipelines, matching the Supaflow UI. Obtain explicit user confirmation immediately before calling.
projects_list
ChatGPTLists projects and their destination datasources.
schedules_create
ChatGPTCreates a five-field cron schedule targeting one pipeline, task, or orchestration.
schedules_delete
ChatGPTSoft-deletes a schedule. Obtain explicit user confirmation immediately before calling.
schedules_disable
ChatGPTSets a schedule to inactive.
schedules_edit
ChatGPTUpdates schedule metadata, cron, timezone, or target.
schedules_enable
ChatGPTSets a schedule to active.
schedules_history
ChatGPTLists recent execution history for a schedule.
schedules_list
ChatGPTLists schedules in a workspace with a maximum page size of 200.
schedules_run
ChatGPTTriggers immediate execution of a schedule.
workspaces_list
ChatGPTLists workspaces accessible to the authenticated user.
