MCP Server
mcp-server
com.dpf-it/mcp-server
What this MCP does
Onboards data sources, generates processing specifications, runs data jobs and SQL queries, and manages SFTP or S3 integrations and schedules.
Capabilities
Tools
18
tools
call_dpf_api
Call any DPF API action (fallback for requests with no dedicated tool)
Escape hatch for DPF capabilities that don't have a dedicated tool yet. ALWAYS prefer a dedicated tool when one exists — get_status, list_data, submit_query, delete_data_spec, onboard_data_source, update_data_spec, run_data_job, manage_connection, manage_trigger, setup_scheduled_pull, list_my_workspaces, create_workspace — and reach for this only when none of those fit (e.g. "how many credits do I have?" -> path "/auth/billing", action "get-balance"; a brand-new action added to the API since this server's tools were last updated). Every DPF endpoint is POST <path> with a JSON body of { action, ...fields }, authenticated with your OAuth session automatically. Pass workspaceId explicitly for workspace-scoped actions (data-specs, connections, job-triggers, and under "/workspaces": get-workspace, list-queries, list-bytes-accessed, list-storage, list-processed-files, list-trigger-runs) — omit it entirely for account-level actions that reject one (under "/workspaces": create, get-workspaces, grant-permission, revoke-permission, update/delete-workspace; under "/auth/billing": get-balance only — billing mutations such as purchase-credits, modify-subscription, manage-payment, and create-customer are NOT available via MCP; direct the user to https://dpf-it.com/workspace.html#credits for all credit and subscription management). If unsure of an action's exact fields, read the "dpf-openapi-spec" resource (dpf://openapi/spec.yaml) rather than guessing. Exception: the raw Iceberg REST proxy under "/iceberg/v1/..." (e.g. to read or set a table's "dpf.primary-keys" property via a commit-table request) does not use the action convention at all — give action any placeholder string (it's ignored) and put the real Iceberg REST commit body, e.g. {"requirements":[],"updates":[{"action":"set-properties","updates":{"dpf.primary-keys":"col_a,col_b"}}]}, in params. This tool only issues POST, so Iceberg's GET-based reads (loadTable, listTables) aren't reachable this way. Returns the raw response data (or, for endpoints like the Iceberg proxy with no {success, data} envelope, the whole response body).
Destructive
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['path', 'action'], 'properties': {'path': {'type': 'string', 'description': 'API path, e.g. "/auth/billing" (leading slash, no query string).'}, 'action': {'type': 'string', 'description': 'The "action" field this endpoint routes on, e.g. "get-balance".'}, 'params': {'type': 'object', 'description': 'Additional action-specific fields to merge into the request body alongside action/workspaceId.', 'additionalProperties': {}}, 'workspaceId': {'type': 'string', 'description': 'Include for workspace-scoped actions. Omit entirely for account-level actions.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'properties': {}, 'additionalProperties': False}
contact
Send a message to the DPF team
Send a message to the DPF team — request a demo, ask about licensing, report an issue, or request a feature. No authentication required. Always ask the user for their email if they have not already given it in this conversation.
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['reason', 'message', 'email'], 'properties': {'name': {'type': 'string'}, 'email': {'type': 'string', 'format': 'email', 'description': "The sender's email address, so DPF can reply."}, 'reason': {'enum': ['request-a-demo', 'understand-licensing', 'report-an-issue', 'request-a-feature'], 'type': 'string'}, 'message': {'type': 'string', 'maxLength': 5000, 'minLength': 1}}, 'additionalProperties': False}
create_workspace
Create a workspace
Create a new workspace, owned by the authenticated user. Use this if list_my_workspaces returns none.
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['name'], 'properties': {'name': {'type': 'string', 'description': 'Workspace name'}, 'description': {'type': 'string', 'description': 'Optional workspace description.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['workspaceId', 'name', 'createdBy', 'createdAt', 'userPermission', 'permission', 'permissions'], 'properties': {'name': {'type': 'string'}, 'createdAt': {'type': 'string'}, 'createdBy': {'type': 'string'}, 'permission': {'type': 'string'}, 'description': {'type': 'string'}, 'permissions': {'type': 'array', 'items': {'type': 'object', 'required': ['userId', 'email', 'permission'], 'properties': {'email': {'type': 'string'}, 'userId': {'type': 'string'}, 'lastName': {'type': 'string'}, 'firstName': {'type': 'string'}, 'permission': {'type': 'string'}}, 'additionalProperties': False}}, 'workspaceId': {'type': 'string'}, 'userPermission': {'type': 'string'}}, 'additionalProperties': False}
delete_data_spec
Delete a data spec
Permanently delete a data spec and its associated configuration.
Destructive
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specName'], 'properties': {'specName': {'type': 'string', 'description': 'Name of the data spec to delete.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specId', 'specName', 'message'], 'properties': {'errors': {'type': 'array', 'items': {'type': 'object', 'required': ['error'], 'properties': {'error': {'type': 'string'}, 'jobId': {'type': 'string'}, 'phase': {'type': 'string'}, 'tableName': {'type': 'string'}}, 'additionalProperties': False}}, 'specId': {'type': 'string'}, 'message': {'type': 'string'}, 'specName': {'type': 'string'}, 'retainedJobs': {'type': 'number'}, 'deletedS3Data': {'type': 'number'}, 'alreadyDeleted': {'type': 'boolean'}, 'deletedS3Specs': {'type': 'number'}, 'deletedTargetTables': {'type': 'number'}}, 'additionalProperties': False}
finish_data_job
Run a data processing job, step 2: start processing after uploading
Call after uploading the file(s) returned by run_data_job — starts processing and waits until the job completes or fails. If it returns before that (timedOut: true), do NOT call this tool again just to keep checking — that re-attempts starting the job. Poll with get_status (jobId) instead until it reaches a terminal status.
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['jobId', 'specName'], 'properties': {'jobId': {'type': 'string', 'description': 'jobId returned by run_data_job.'}, 'specName': {'type': 'string', 'description': 'Name of the data spec this job belongs to.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message'], 'properties': {'error': {'type': 'string'}, 'jobId': {'type': 'string'}, 'specId': {'type': 'string'}, 'status': {'type': 'string', 'description': '"processing" | "completed" | "failed"'}, 'endTime': {'type': 'string'}, 'jobSize': {'type': 'string'}, 'message': {'type': 'string'}, 'metrics': {'type': 'object', 'additionalProperties': {}}, 'progress': {'type': 'number'}, 'timedOut': {'type': 'boolean'}, 'startTime': {'type': 'string'}, 'durationMs': {'type': 'number'}, 'logLocation': {'type': 'string'}, 'workspaceId': {'type': 'string'}, 'errorDetails': {'type': 'string'}, 'currentLambda': {'type': 'string'}, 'statusMessage': {'type': 'string'}, 'creditsCharged': {'type': 'number'}}, 'additionalProperties': False}
finish_data_source_onboarding
Onboard a new data source, step 2: run analysis after uploading
Call after uploading the file(s) returned by onboard_data_source — kicks off AI analysis and waits until the spec reaches "ready" or "failed". If it returns before that (timedOut: true), do NOT call this tool again just to keep checking — that re-attempts starting analysis. Poll with get_status (specId) instead until it reaches a terminal status.
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specId', 'specName'], 'properties': {'specId': {'type': 'string', 'description': 'specId returned by onboard_data_source.'}, 'specName': {'type': 'string', 'description': 'Name of the data spec being onboarded.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}, 'loadSampleData': {'type': 'boolean', 'description': 'Whether to load the sample file and trigger the data-load job once analysis finishes (default true).'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message'], 'properties': {'error': {'type': ['string', 'null']}, 'specId': {'type': 'string'}, 'status': {'type': 'string', 'description': '"processing" | "ready" | "failed"'}, 'message': {'type': 'string'}, 'progress': {'type': 'number'}, 'timedOut': {'type': 'boolean'}, 'lastJobId': {'type': ['string', 'null']}, 'workspaceId': {'type': 'string'}, 'errorDetails': {'type': ['string', 'null']}, 'statusMessage': {'type': 'string'}, 'analysisEndTime': {'type': ['string', 'null']}, 'analysisStartTime': {'type': ['string', 'null']}, 'analysisDurationMs': {'type': ['number', 'null']}, 'hasTransformationConfig': {'type': 'boolean'}}, 'additionalProperties': False}
finish_data_spec_update
Update an existing data spec, step 2: run analysis after uploading
Call after uploading the file(s) returned by update_data_spec — kicks off AI analysis and waits until the spec reaches "ready" or "failed". If it returns before that (timedOut: true), do NOT call this tool again just to keep checking — that re-attempts starting analysis. Poll with get_status (specId) instead until it reaches a terminal status.
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specId', 'specName'], 'properties': {'specId': {'type': 'string', 'description': 'specId returned by update_data_spec.'}, 'specName': {'type': 'string', 'description': 'Name of the data spec being updated.'}, 'runAnalysis': {'type': 'boolean', 'description': 'Default true — set false to skip analysis and just confirm the upload.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}, 'loadSampleData': {'type': 'boolean', 'description': 'Whether analysis should also trigger the data-load job (default true).'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message'], 'properties': {'error': {'type': ['string', 'null']}, 'specId': {'type': 'string'}, 'status': {'type': 'string', 'description': '"processing" | "ready" | "failed"'}, 'message': {'type': 'string'}, 'progress': {'type': 'number'}, 'timedOut': {'type': 'boolean'}, 'lastJobId': {'type': ['string', 'null']}, 'workspaceId': {'type': 'string'}, 'errorDetails': {'type': ['string', 'null']}, 'statusMessage': {'type': 'string'}, 'analysisEndTime': {'type': ['string', 'null']}, 'analysisStartTime': {'type': ['string', 'null']}, 'analysisDurationMs': {'type': ['number', 'null']}, 'hasTransformationConfig': {'type': 'boolean'}}, 'additionalProperties': False}
get_status
Get spec or job status
Poll the status of either a data spec's own process (schema inference + code generation, run by start-analysis — pass specId, reaches "ready" or "failed") or a data-load job (pass jobId, reaches "complete" or "failed"). Pass exactly one of specId or jobId. Right after create-spec/update-spec + start-analysis, poll by specId; once that reaches "ready", its response's lastJobId (if present) points at the data-load job — poll that separately by jobId for load progress.
Read only
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'properties': {'jobId': {'type': 'string', 'description': "Poll a data-load job's status. Pass exactly one of specId or jobId."}, 'specId': {'type': 'string', 'description': "Poll a data spec's analysis status. Pass exactly one of specId or jobId."}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'properties': {'error': {'type': ['string', 'null']}, 'jobId': {'type': 'string'}, 'specId': {'type': 'string'}, 'status': {'type': 'string', 'description': 'e.g. "processing" | "ready" | "failed" for a spec; "processing" | "completed" | "failed" for a job'}, 'endTime': {'type': 'string'}, 'jobSize': {'type': 'string'}, 'metrics': {'type': 'object', 'description': 'Present once a job completes: recordsRead, recordsWritten, filesProcessed, etc.', 'additionalProperties': {}}, 'progress': {'type': 'number'}, 'lastJobId': {'type': ['string', 'null'], 'description': 'spec poll only: the data-load job triggered once analysis reaches "ready".'}, 'startTime': {'type': 'string'}, 'durationMs': {'type': 'number'}, 'logLocation': {'type': 'string'}, 'workspaceId': {'type': 'string'}, 'errorDetails': {'type': ['string', 'null']}, 'currentLambda': {'type': 'string'}, 'statusMessage': {'type': 'string'}, 'creditsCharged': {'type': 'number'}, 'analysisEndTime': {'type': ['string', 'null']}, 'analysisStartTime': {'type': ['string', 'null']}, 'analysisDurationMs': {'type': ['number', 'null']}, 'hasTransformationConfig': {'type': 'boolean'}}, 'additionalProperties': False}
list_data
List data specs or jobs
List either the data specs (parsing + mapping rule sets, resource: "specs") or the data processing jobs (executions of a spec, resource: "jobs") defined in a workspace. Each spec includes its specId and current status — poll a specific one with get_status. Both resources are paginated (default 25/page, max 100, newest first); pass the returned nextCursor to fetch more.
This is NOT a table listing — specs describe configured pipelines (parsing/mapping rules), not the live set of Iceberg tables in the workspace. Multiple specs can target the same table (e.g. one spec creates it, another merges more data into it), and specs can be deleted or fail without the underlying table being dropped. For "what tables exist in my workspace" or any question about actual current data, use submit_query with `SHOW TABLES` instead of inferring an answer from specs.
Read only
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['resource'], 'properties': {'cursor': {'type': 'string', 'description': 'Opaque `nextCursor` from a prior page (omit for the first page).'}, 'pageSize': {'type': 'integer', 'maximum': 100, 'minimum': 1, 'description': 'Records per page (default 25).'}, 'resource': {'enum': ['specs', 'jobs'], 'type': 'string', 'description': 'Which kind of resource to list'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['count'], 'properties': {'jobs': {'type': 'array', 'items': {'type': 'object', 'required': ['jobId', 'specId'], 'properties': {'error': {'type': 'string'}, 'jobId': {'type': 'string'}, 'specId': {'type': 'string'}, 'status': {'type': 'string'}, 'endTime': {'type': 'string'}, 'jobSize': {'type': 'string'}, 'progress': {'type': 'number'}, 'specName': {'type': 'string'}, 'createdAt': {'type': 'string'}, 'createdBy': {'type': 'string'}, 'startTime': {'type': 'string'}, 'durationMs': {'type': 'number'}, 'workspaceId': {'type': 'string'}, 'errorDetails': {'type': 'string'}, 'statusMessage': {'type': 'string'}, 'creditsCharged': {'type': 'number'}}, 'additionalProperties': False}, 'description': 'Present when resource is "jobs"'}, 'count': {'type': 'number', 'description': 'Number of items in this page, not the workspace total'}, 'specs': {'type': 'array', 'items': {'type': 'object', 'required': ['specId', 'specName'], 'properties': {'error': {'type': ['string', 'null']}, 'merge': {'type': 'boolean'}, 'specId': {'type': 'string'}, 'status': {'type': 'string'}, 'progress': {'type': 'number'}, 'specName': {'type': 'string'}, 'createdAt': {'type': 'string'}, 'createdBy': {'type': 'string'}, 'lastJobId': {'type': ['string', 'null']}, 'updatedAt': {'type': 'string'}, 'computeSize': {'enum': ['small', 'large'], 'type': 'string'}, 'description': {'type': 'string'}, 'errorDetails': {'type': ['string', 'null']}, 'targetOption': {'enum': ['existing-tables', 'target-schema-file', 'auto-infer'], 'type': 'string'}, 'targetTables': {'type': 'array', 'items': {'type': 'string'}}, 'statusMessage': {'type': 'string'}, 'targetSchemaFileName': {'type': 'string'}, 'hasTransformationConfig': {'type': 'boolean'}}, 'additionalProperties': False}, 'description': 'Present when resource is "specs"'}, 'pageSize': {'type': 'number'}, 'nextCursor': {'type': ['string', 'null'], 'description': 'Opaque cursor for the next page; null when exhausted'}}, 'additionalProperties': False}
list_my_workspaces
List my workspaces
List every workspace the authenticated user has access to, including their permission on each.
Read only
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'properties': {}}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['workspaces', 'count'], 'properties': {'count': {'type': 'number'}, 'workspaces': {'type': 'array', 'items': {'type': 'object', 'required': ['workspaceId', 'name', 'createdBy', 'createdAt', 'userPermission', 'permissions'], 'properties': {'name': {'type': 'string'}, 'createdAt': {'type': 'string'}, 'createdBy': {'type': 'string'}, 'description': {'type': 'string'}, 'permissions': {'type': 'array', 'items': {'type': 'object', 'required': ['userId', 'email', 'permission'], 'properties': {'email': {'type': 'string'}, 'userId': {'type': 'string'}, 'lastName': {'type': 'string'}, 'firstName': {'type': 'string'}, 'permission': {'type': 'string'}}, 'additionalProperties': False}}, 'workspaceId': {'type': 'string'}, 'userPermission': {'type': 'string'}}, 'additionalProperties': False}}}, 'additionalProperties': False}
manage_account
Get instructions for DPF account signup, email verification, or password reset
Returns instructions for creating a DPF account, verifying its email, resending the verification code, or resetting a forgotten password — it never performs these itself and never asks for a password. A password typed into this chat would sit in the conversation transcript, so every action instead returns the DPF website's own form, or a curl command that reads the password from a shell variable the user sets themselves in their own terminal. Hand the command to the user to run — do not run it yourself even if you have shell access, since composing the export line would require seeing the password. action "register": requires email, firstName, lastName, and termsAccepted: true (only after the user has explicitly agreed to the DPF Terms of Service and Privacy Policy in this conversation). action "verify": confirm the 6-digit code DPF emailed after registration (requires otp). action "resend": re-send that code if it never arrived. action "forgot-password": request a password-reset code (requires email). action "reset-password": submit that code and set a new password (requires otp).
Read only
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['action', 'email'], 'properties': {'otp': {'type': 'string', 'pattern': '^\\d{6}$', 'description': 'action "verify" and "reset-password" only. The 6-digit code from the email DPF sent.'}, 'email': {'type': 'string', 'format': 'email'}, 'action': {'enum': ['register', 'verify', 'resend', 'forgot-password', 'reset-password'], 'type': 'string'}, 'lastName': {'type': 'string', 'description': 'action "register" only'}, 'firstName': {'type': 'string', 'description': 'action "register" only'}, 'termsAccepted': {'type': 'boolean', 'description': 'action "register" only. Must be true.'}}, 'additionalProperties': False}
manage_connection
Manage an external data-source connection (SFTP, AWS S3)
Create, list, test, or delete a workspace connection to an external data source. Two types are supported: "sftp" and "aws_s3". For sftp, create generates a keypair and returns the public key — it must be installed in the remote server's authorized_keys before test (or a trigger using this connection) will succeed. For aws_s3, create generates an ExternalId and returns a trustPolicy plus dpfPrincipalArn — the customer must create (or update) the IAM role at roleArn with that trust policy and a permissions policy granting the S3 access DPF needs, before test will succeed. Either type must pass test before it can be used in a trigger. For a first-time "pull files from this server/bucket on a schedule" request, prefer setup_scheduled_pull, which chains create + test + create-trigger for you.
Destructive
Open world
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['action'], 'properties': {'type': {'enum': ['sftp', 'aws_s3'], 'type': 'string', 'description': 'Connection type. Required for create; defaults to "sftp".'}, 'action': {'enum': ['create', 'list', 'test', 'delete'], 'type': 'string', 'description': 'Which operation to perform.'}, 'roleArn': {'type': 'string', 'description': 'aws_s3 only. The IAM role the customer will create/update. Required for create.'}, 'hostname': {'type': 'string', 'description': 'sftp only. Remote server hostname. Required for create.'}, 'username': {'type': 'string', 'description': 'sftp only. Remote username. Optional for create; defaults to "sftpuser".'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}, 'connectionId': {'type': 'string', 'description': 'Existing connection to test or delete. Required for test/delete.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'properties': {'type': {'enum': ['sftp', 'aws_s3'], 'type': 'string'}, 'count': {'type': 'number', 'description': 'action "list" only'}, 'account': {'type': 'string', 'description': 'action "test", type "aws_s3" only'}, 'message': {'type': 'string'}, 'roleArn': {'type': 'string'}, 'success': {'type': 'boolean', 'description': 'action "test" only'}, 'hostname': {'type': 'string'}, 'username': {'type': 'string'}, 'createdAt': {'type': 'number'}, 'createdBy': {'type': 'string'}, 'fileCount': {'type': 'number', 'description': 'action "test", type "sftp" only'}, 'publicKey': {'type': 'string'}, 'updatedAt': {'type': 'number'}, 'entryCount': {'type': 'number', 'description': 'action "test", type "sftp" only'}, 'externalId': {'type': 'string'}, 'connections': {'type': 'array', 'items': {'type': 'object', 'additionalProperties': {}}, 'description': 'action "list" only'}, 'trustPolicy': {'type': 'object', 'additionalProperties': {}}, 'workspaceId': {'type': 'string'}, 'connectionId': {'type': 'string'}, 'lastTestedAt': {'type': 'number'}, 'assumedRoleArn': {'type': 'string', 'description': 'action "test", type "aws_s3" only'}, 'lastTestStatus': {'enum': ['passed', 'failed'], 'type': 'string'}, 'dpfPrincipalArn': {'type': 'string'}}, 'additionalProperties': False}
manage_trigger
Manage a workspace trigger (SFTP/AWS S3 pull, spec chaining, or schedule)
Create, list, update, delete, or fire a workspace job trigger. Four types:
- "sftp"/"aws_s3": pulls files from a connection (sftp: remote server; aws_s3: S3 bucket/prefix) into an already-analyzed data spec on a schedule (hourly/daily/monthly, UTC). Type must match the connection's type; aws_s3 also requires s3Bucket (s3Prefix optional). Natural-language preRules (which files to pick up) and postRules (what to do after upload) are compiled into executable code server-side — never pass raw code. The connection must already exist and have passed test (see manage_connection). For a first-time "set up a daily/scheduled pull" request, prefer setup_scheduled_pull, which sets up the connection and trigger together.
- "spec_success": fires a spec automatically whenever a DIFFERENT spec's job completes successfully (set upstreamSpecName to that spec). No connection/frequency. Use this when the request ties the run to another job finishing (e.g. "run this after the customers load finishes").
- "schedule": fires a spec directly on a plain frequency (hourly/daily/monthly, UTC), no connection and no upstream spec. Use this when the request is time-based with no dependency (e.g. "run this every morning").
IMPORTANT: "spec_success" and "schedule" triggers can only target a table-source (sourceType: "tables") or compaction (sourceType: "compaction") spec (see onboard_data_source) — they have no file to load, only a generated query to re-run or a set of tables to compact. If asked to set up a scheduled/recurring job that reads from an already-loaded table (e.g. "keep a daily summary of the orders table up to date"), create that as an onboard_data_source sourceType "tables" spec first, THEN create the trigger here. Same for a recurring compaction — create the sourceType "compaction" spec first. Prefer "spec_success" when the user's phrasing implies "after X loads/finishes"; prefer "schedule" when they just want a cadence with no stated dependency; ask if genuinely ambiguous. For sftp/aws_s3, the referenced spec must already have been analyzed once (see onboard_data_source).
After firing a trigger (action "run-now") — or any one-off manual run — use action "run-history" to monitor its outcome: it starts as `status: running` and settles to `success`, `failed`, or `no-files`, with `filesPulled` and a `message`.
Destructive
Open world
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['action'], 'properties': {'type': {'enum': ['sftp', 'aws_s3', 'spec_success', 'schedule'], 'type': 'string', 'description': 'Trigger type. Optional for create (defaults to "sftp"). For sftp/aws_s3 must match the connection\'s type.'}, 'action': {'enum': ['create', 'list', 'update', 'delete', 'run-now', 'clear-processed-files', 'run-history'], 'type': 'string', 'description': 'Which operation to perform.'}, 'cursor': {'type': 'string', 'description': 'run-history: opaque `nextCursor` from a prior page (omit for the first page).'}, 'dedupe': {'type': 'boolean', 'description': "sftp/aws_s3 only. Required for create — ask the user rather than assuming a value; do not default it silently. Whether repeat pulls should skip files already loaded into this spec, matched by file name. Has real consequences: with dedupe true, a file that reappears under the same name (e.g. re-uploaded with corrected data) will be silently skipped; with dedupe false, an unchanged file left on the server will be reloaded every run. Omit only for update, where omitting leaves the trigger's existing setting unchanged."}, 'specId': {'type': 'string', 'description': 'run-history: filter to runs of triggers feeding this spec.'}, 'enabled': {'type': 'boolean', 'description': 'Whether the trigger is active. Defaults to true on create.'}, 'endTime': {'type': 'string', 'description': 'run-history: ISO 8601 upper bound (inclusive) on when the run started.'}, 'pageSize': {'type': 'integer', 'maximum': 100, 'minimum': 1, 'description': 'run-history: records per page (default 25).'}, 'preRules': {'type': 'string', 'description': 'sftp/aws_s3 only. Natural language: which files to pick up (e.g. "only *.csv under /outbound").'}, 's3Bucket': {'type': 'string', 'description': 'aws_s3 only. Bucket to poll. Required for create when type is "aws_s3", or to change it on update. Each run lists at most 5000 objects from the bucket/prefix (oldest key first) — past that, new files can be missed. On create, a successful response includes a `warnings` array with this note; relay it to the user and suggest an S3 lifecycle rule to expire/transition old objects.'}, 's3Prefix': {'type': 'string', 'description': 'aws_s3 only. Optional key prefix; defaults to the whole bucket.'}, 'specName': {'type': 'string', 'description': 'The spec this trigger fires. Required for create.'}, 'frequency': {'type': 'object', 'required': ['unit'], 'properties': {'unit': {'enum': ['hourly', 'daily', 'monthly'], 'type': 'string', 'description': 'Schedule cadence.'}, 'hourOfDay': {'type': 'integer', 'maximum': 23, 'minimum': 0, 'description': 'Required for daily/monthly (UTC).'}, 'dayOfMonth': {'type': 'integer', 'maximum': 31, 'minimum': 1, 'description': 'Required for monthly.'}}, 'description': 'Required for create when type is "sftp", "aws_s3", or "schedule"; optional on update to change the schedule. Not applicable to spec_success.', 'additionalProperties': False}, 'postRules': {'type': 'string', 'description': 'sftp/aws_s3 only. Natural language: what to do after a file loads (e.g. "rename with .done suffix").'}, 'startTime': {'type': 'string', 'description': 'run-history: ISO 8601 lower bound (inclusive) on when the run started.'}, 'triggerId': {'type': 'string', 'description': 'Existing trigger. Required for update/delete/run-now/clear-processed-files.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}, 'connectionId': {'type': 'string', 'description': 'sftp/aws_s3 only. Connection to pull from. Required for create when type is "sftp"/"aws_s3". Also usable as a run-history filter.'}, 'upstreamSpecName': {'type': 'string', 'description': 'spec_success only. The spec whose successful job completion fires this trigger. Required for create when type is "spec_success".'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'properties': {'runs': {'type': 'array', 'items': {'type': 'object', 'required': ['triggerId', 'startedAt', 'status', 'filesPulled', 'message'], 'properties': {'jobId': {'type': 'string'}, 'specId': {'type': 'string'}, 'status': {'enum': ['running', 'success', 'failed', 'no-files'], 'type': 'string'}, 'message': {'type': 'string'}, 'specName': {'type': 'string'}, 'startedAt': {'type': 'string'}, 'triggerId': {'type': 'string'}, 'finishedAt': {'type': 'string'}, 'filesPulled': {'type': 'number'}, 'workspaceId': {'type': 'string'}, 'connectionId': {'type': 'string'}}, 'additionalProperties': False}, 'description': 'action "run-history" only'}, 'type': {'enum': ['sftp', 'aws_s3', 'spec_success', 'schedule'], 'type': 'string'}, 'count': {'type': 'number', 'description': 'action "list" only'}, 'dedupe': {'type': 'boolean'}, 'specId': {'type': 'string'}, 'deleted': {'type': 'number', 'description': 'action "clear-processed-files" only'}, 'enabled': {'type': 'boolean'}, 'message': {'type': 'string'}, 'pageSize': {'type': 'number', 'description': 'action "run-history" only'}, 'preRules': {'type': 'string'}, 's3Bucket': {'type': 'string'}, 's3Prefix': {'type': 'string'}, 'specName': {'type': 'string'}, 'triggers': {'type': 'array', 'items': {'type': 'object', 'additionalProperties': {}}, 'description': 'action "list" only'}, 'warnings': {'type': 'array', 'items': {'type': 'string'}, 'description': 'action "create", type "aws_s3" only. Advisory notes, e.g. the 5000-object S3 listing cap — relay to the user.'}, 'createdAt': {'type': 'number'}, 'createdBy': {'type': 'string'}, 'frequency': {'type': 'object', 'required': ['unit'], 'properties': {'unit': {'enum': ['hourly', 'daily', 'monthly'], 'type': 'string'}, 'hourOfDay': {'type': 'number'}, 'dayOfMonth': {'type': 'number'}}, 'additionalProperties': False}, 'lastJobId': {'type': 'string'}, 'lastRunAt': {'type': 'number'}, 'postRules': {'type': 'string'}, 'triggerId': {'type': 'string'}, 'updatedAt': {'type': 'number'}, 'nextCursor': {'type': ['string', 'null'], 'description': 'action "run-history" only'}, 'workspaceId': {'type': 'string'}, 'connectionId': {'type': 'string'}, 'lastRunStatus': {'type': 'string'}, 'upstreamSpecId': {'type': 'string', 'description': 'type "spec_success" only'}, 'upstreamSpecName': {'type': 'string', 'description': 'type "spec_success" only'}}, 'additionalProperties': False}
onboard_data_source
Onboard a new data source, step 1: create a data spec and get upload URL(s)
First step of setting up a new data integration: creates a data spec. By default (sourceType "file") this returns presigned upload URL(s) for the sample file (and optional format/target-schema file) — upload the file(s) per the returned instructions, then call finish_data_source_onboarding with the returned specId to kick off AI analysis and wait for it to complete.
Use sourceType "tables" instead when the request is to derive/aggregate data that is ALREADY loaded into workspace tables — e.g. "build me a daily summary of the customers table", or "set up a job that reads from the orders table and maintains a running total" — rather than loading a new file. It generates a SQL query (INSERT or MERGE, per `merge`) via AI instead of a Python parser, run through the query engine instead of a Glue job. There are never sample/format files, but targetOption still works the same three ways as sourceType "file" (see targetOption below) — so this call returns files: [] and you can call finish_data_source_onboarding immediately UNLESS targetOption is "target-schema-file", in which case it returns one upload URL for that file, same as the file-source path. The generated SQL automatically windows itself to rows added since the spec's last successful run. sourceType "tables" ALSO requires autoRefresh — how this spec stays up to date is not optional to decide, and must not be inferred from other jobs/triggers that happen to already exist in the workspace: ask the user whether it should re-run automatically whenever a specific upstream spec finishes loading ("spec_success" — the natural choice when the request is "run this after X finishes/loads"), on a plain cron-like cadence ("schedule" — the natural choice when the request is "run this every day/hour" with no mention of depending on another job), or stay manual-only ("none" — re-run later with run_data_job). If the request already states the timing unambiguously, that answers it; otherwise ask before calling this tool. Getting this wrong either way has a real cost: "none" means the summary silently goes stale until someone remembers to re-run it by hand, while an unwanted trigger keeps re-running (and charging credits for) a spec the user only wanted once. See autoRefresh below.
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specName'], 'properties': {'merge': {'type': 'boolean', 'description': 'Upsert instead of plain append when true (default false). For sourceType "tables": generates a MERGE statement instead of an INSERT — use true for a running aggregate/summary that updates existing rows. For sourceType "file" with targetOption "existing-tables": upserts loaded rows by the target table\'s inferred key instead of always inserting — use true whenever the request implies re-loading the same rows shouldn\'t create duplicates (e.g. "upsert on id", syncing/backfilling into a table that already has overlapping rows). Already automatic, no need to request it via additionalPrompt: target columns with no corresponding source column are null on newly inserted rows, and on a match keep their existing value rather than being nulled out.'}, 'specName': {'type': 'string', 'description': 'Name for the new data spec.'}, 'sourceType': {'enum': ['file', 'tables', 'compaction'], 'type': 'string', 'description': 'Defaults to "file" (upload a sample file). Use "tables" to query existing workspace table(s) — see sourceTables — instead of loading a new file. Use "compaction" to bin-pack the small data files of existing tables: it moves no data and produces no new table, so it takes NO target of any kind, needs no analysis, and is ready to run the moment it is created.'}, 'autoRefresh': {'enum': ['spec_success', 'schedule', 'none'], 'type': 'string', 'description': 'sourceType "tables" only. Required for it — ask the user rather than assuming, and do not infer this from other jobs/triggers already in the workspace (a similar existing pipeline is not the user\'s answer for this one). "spec_success" re-runs this spec whenever autoRefreshUpstreamSpecName finishes loading; "schedule" re-runs it on autoRefreshFrequency; "none" leaves it manual-only (re-run later with run_data_job).'}, 'description': {'type': 'string', 'description': 'Optional description of the data spec.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}, 'sourceTables': {'type': 'array', 'items': {'type': 'string'}, 'description': 'Names of existing workspace tables. Required for sourceType "tables" (the tables the generated query reads from) and for sourceType "compaction" (the tables to compact).'}, 'targetOption': {'enum': ['auto-infer', 'existing-tables', 'target-schema-file'], 'type': 'string', 'description': 'Where transformed data should land — works the same for both sourceType values: "auto-infer" (default) lets the AI design the target table (for sourceType "tables", it designs the schema and the query together in one pass), "existing-tables" uses a table already in the workspace (requires targetTables), "target-schema-file" creates the table from a provided schema file (requires targetSchemaFileName).'}, 'targetTables': {'type': 'array', 'items': {'type': 'string'}, 'description': 'Names of existing workspace tables to target — exactly one entry for sourceType "tables" (the generated query has a single target), one or more for sourceType "file". Required when targetOption is "existing-tables". Optional otherwise: for "target-schema-file"/"auto-infer" the target table (and its name) is derived automatically — from the schema file, or AI-designed — unless you want to pin the name yourself, in which case pass exactly one entry.'}, 'formatFileName': {'type': 'string', 'description': 'sourceType "file" only. File name of an optional format spec file.'}, 'sampleFileName': {'type': 'string', 'description': 'sourceType "file" only (and required for it). File name of the sample data file (e.g. "customers.csv") — used to derive content-type, not read from disk.'}, 'additionalPrompt': {'type': 'string', 'description': 'Instructions for the AI. For sourceType "tables", describe what the query should compute from the source table(s) (e.g. "count signups per day per region"). This is stored on the spec verbatim and reused on every future re-analysis, so keep it to instructions that actually change behavior — do not restate default platform behavior (e.g. that unmapped target columns are null/preserved, see merge above) just to document it, since a note that\'s only true for one case (like new rows) can read as a standing instruction later and cause confusion on updates.'}, 'autoRefreshFrequency': {'type': 'object', 'required': ['unit'], 'properties': {'unit': {'enum': ['hourly', 'daily', 'monthly'], 'type': 'string', 'description': 'Schedule cadence.'}, 'hourOfDay': {'type': 'integer', 'maximum': 23, 'minimum': 0, 'description': 'Required for daily/monthly (UTC).'}, 'dayOfMonth': {'type': 'integer', 'maximum': 31, 'minimum': 1, 'description': 'Required for monthly.'}}, 'description': 'Required when autoRefresh is "schedule".', 'additionalProperties': False}, 'expirePriorSnapshots': {'type': 'boolean', 'description': 'sourceType "compaction" only, default false. When false the job commits the compacted files and changes nothing else — prior snapshots still reference the replaced files, so no storage is freed. When true it also expires every snapshot older than its own commit and deletes the replaced files in the same run, which frees storage but ends the ability to roll back to before the compaction.'}, 'targetSchemaFileName': {'type': 'string', 'description': 'File name of a target schema file. Required when targetOption is "target-schema-file", for either sourceType.'}, 'autoRefreshUpstreamSpecName': {'type': 'string', 'description': 'Required when autoRefresh is "spec_success". The spec whose successful job completion should re-run this one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message', 'specId', 'specName', 'files', 'nextStep'], 'properties': {'files': {'type': 'array', 'items': {'type': 'object', 'required': ['fileName', 'url', 'contentType'], 'properties': {'url': {'type': 'string'}, 'fileName': {'type': 'string'}, 'contentType': {'type': 'string'}}, 'additionalProperties': False}}, 'specId': {'type': 'string'}, 'message': {'type': 'string'}, 'nextStep': {'type': 'string', 'description': 'The finish_data_source_onboarding call to make (once upload(s) are done, or immediately for sourceType "tables").'}, 'specName': {'type': 'string'}, 'triggerId': {'type': 'string', 'description': 'sourceType "tables" only, when autoRefresh was not "none": the auto-refresh trigger created alongside the spec.'}}, 'additionalProperties': False}
run_data_job
Run a data processing job, step 1: create job and get upload URL(s)
First step of processing new data files through an already-configured data spec: creates a job and returns presigned upload URL(s) for each file. Upload the file(s) per the returned instructions, then call finish_data_job with the returned jobId to start processing and wait for it to complete.
Do NOT call this right after onboard_data_source/finish_data_source_onboarding or update_data_spec/finish_data_spec_update unless loadSampleData was explicitly set to false there — by default those already load and process the sample file as their own job (see the returned lastJobId), so calling run_data_job again for that same file creates a redundant second job. Only use this for files beyond the initial sample (new batches, additional files to process later).
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specName', 'fileNames'], 'properties': {'specName': {'type': 'string', 'description': 'Name of the already-configured data spec to process files through.'}, 'fileNames': {'type': 'array', 'items': {'type': 'string'}, 'minItems': 1, 'description': 'File names of the data files to process (e.g. ["jan.csv", "feb.csv"])'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message', 'jobId', 'specName', 'files', 'nextStep'], 'properties': {'files': {'type': 'array', 'items': {'type': 'object', 'required': ['fileName', 'url', 'contentType'], 'properties': {'url': {'type': 'string'}, 'fileName': {'type': 'string'}, 'contentType': {'type': 'string'}}, 'additionalProperties': False}}, 'jobId': {'type': 'string'}, 'message': {'type': 'string'}, 'nextStep': {'type': 'string', 'description': 'The finish_data_job call to make once upload(s) are done.'}, 'specName': {'type': 'string'}}, 'additionalProperties': False}
setup_scheduled_pull
Set up a scheduled SFTP or S3 pull into an existing data spec
End-to-end workflow for "pull files from this SFTP server / S3 bucket on a schedule" requests: reuses a matching connection if one already exists in the workspace (same hostname/username for sftp, same roleArn for aws_s3), otherwise creates one; tests it; then creates a trigger that feeds an already-analyzed data spec (see onboard_data_source) on the given frequency. Pass hostname for an sftp pull, or roleArn (+ s3Bucket, required) for an aws_s3 pull — exactly one of the two is expected. Use this instead of calling manage_connection + manage_trigger yourself for first-time setup. If the connection test fails (e.g. the sftp public key or the aws_s3 IAM role isn't set up yet on the customer's side), no trigger is created — ask the user to finish that setup and re-run this tool, which will reuse the same connection and pick up where it left off. This is for pulling a NEW file from an external source — for "run this on a schedule/after another job" where the spec queries tables already in the workspace (sourceType "tables"), use manage_trigger with type "schedule" or "spec_success" instead; there is no connection involved.
Open world
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specName', 'frequency'], 'properties': {'dedupe': {'type': 'boolean', 'description': 'Required — ask the user rather than assuming a value; omitting it fails the call. Whether repeat pulls should skip files already loaded into this spec, matched by file name. Has real consequences: with dedupe true, a file that reappears under the same name (e.g. re-uploaded with corrected data) will be silently skipped; with dedupe false, an unchanged file left on the server will be reloaded every run.'}, 'roleArn': {'type': 'string', 'description': 'aws_s3: the IAM role the customer will create/update.'}, 'hostname': {'type': 'string', 'description': 'sftp: SFTP server hostname to pull from.'}, 'preRules': {'type': 'string', 'description': 'Natural language: which files to pick up (e.g. "only *.csv under /outbound")'}, 's3Bucket': {'type': 'string', 'description': 'aws_s3: bucket to poll. Required when roleArn is given.'}, 's3Prefix': {'type': 'string', 'description': 'aws_s3 only. Optional key prefix; defaults to the whole bucket.'}, 'specName': {'type': 'string', 'description': 'Already-analyzed data spec to load files into (see onboard_data_source)'}, 'username': {'type': 'string', 'description': 'sftp only. Defaults to "sftpuser".'}, 'frequency': {'type': 'object', 'required': ['unit'], 'properties': {'unit': {'enum': ['hourly', 'daily', 'monthly'], 'type': 'string', 'description': 'Schedule cadence.'}, 'hourOfDay': {'type': 'integer', 'maximum': 23, 'minimum': 0, 'description': 'Required for daily/monthly (UTC).'}, 'dayOfMonth': {'type': 'integer', 'maximum': 31, 'minimum': 1, 'description': 'Required for monthly.'}}, 'description': 'Pull schedule.', 'additionalProperties': False}, 'postRules': {'type': 'string', 'description': 'Natural language: what to do after a file loads (e.g. "rename with .done suffix")'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message'], 'properties': {'dedupe': {'type': 'boolean'}, 'specId': {'type': 'string'}, 'enabled': {'type': 'boolean'}, 'message': {'type': 'string'}, 's3Bucket': {'type': 'string'}, 's3Prefix': {'type': 'string'}, 'specName': {'type': 'string'}, 'warnings': {'type': 'array', 'items': {'type': 'string'}, 'description': 'aws_s3 only. Advisory notes about the created trigger, e.g. the 5000-object S3 listing cap.'}, 'frequency': {'type': 'object', 'required': ['unit'], 'properties': {'unit': {'enum': ['hourly', 'daily', 'monthly'], 'type': 'string'}, 'hourOfDay': {'type': 'number'}, 'dayOfMonth': {'type': 'number'}}, 'additionalProperties': False}, 'triggerId': {'type': 'string', 'description': 'Present only once the connection test succeeded and a trigger was created.'}, 'connectionId': {'type': 'string'}, 'testSucceeded': {'type': 'boolean'}, 'connectionType': {'enum': ['sftp', 'aws_s3'], 'type': 'string'}}, 'additionalProperties': False}
submit_query
Query workspace data
Run a SQL query against the Iceberg tables loaded into a workspace. To list the tables that actually exist in the workspace, run `SHOW TABLES` — this is the authoritative source (unlike list_data's specs, which describe pipelines, not live tables). Qualified table references (catalog/schema prefixes, e.g. information_schema.tables) are rejected; reference tables by name only. Table functions that introspect the engine itself (e.g. duckdb_functions(), duckdb_tables()) are also rejected as external-data-source access — don't try to discover available SQL functions this way. A BLOB column is very likely an HLL sketch (produced by a merge-mode table-source spec's approximate-distinct aggregate — see onboard_data_source's merge option): decode it with datasketch_hll_estimate(col), or datasketch_hll_estimate(datasketch_hll_union(12, col)) to union several rows to a coarser grain first. If the user's goal is an HTML page/dashboard built from these results (not just seeing the data here), do NOT default to embedding this result set as a static snapshot. Ask the user first: (a) a one-time static page with these results baked in, which goes stale and never changes again, or (b) a live page that logs in and queries DPF itself whenever it's opened, so it always reflects current data. If they want live/dynamic (or don't say and the data looks like it changes over time), read the dpf://examples/auth-and-query.html resource and adapt that pattern (login form, JWT cookie, fetch-based query call) instead of hand-rolling auth.
Read only
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['sql'], 'properties': {'sql': {'type': 'string', 'description': 'SQL query, e.g. SELECT * FROM customers LIMIT 10'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['schema', 'rows'], 'properties': {'rows': {'type': 'array', 'items': {'type': 'object', 'additionalProperties': {}}}, 'schema': {'type': 'array', 'items': {'type': 'object', 'required': ['name', 'type'], 'properties': {'name': {'type': 'string'}, 'type': {'type': 'string'}}, 'additionalProperties': False}, 'description': 'Column name -> DuckDB type'}, 'rowCount': {'type': 'number'}, 'executionTimeMs': {'type': 'number'}}, 'additionalProperties': False}
update_data_spec
Update an existing data spec
Change an existing data spec's configuration. If no replacement file names are given, this runs synchronously (no upload needed): saves changes and — by default — re-runs AI analysis, returning the final status directly. If a replacement sample/format/target-schema file name IS given, this instead returns presigned upload URL(s); upload the file(s), then call finish_data_spec_update. Only pass the fields you want to change — omitted fields keep their current value.
Idempotent
Input schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['specName'], 'properties': {'merge': {'type': 'boolean', 'description': 'Whether new data should merge/upsert into existing rows rather than append. For sourceType "tables" also changes the generated SQL between MERGE and INSERT.'}, 'specName': {'type': 'string', 'description': 'Name of the existing data spec to update'}, 'computeSize': {'enum': ['small', 'large'], 'type': 'string', 'description': 'Compute size for analysis/processing. Omit to keep the current setting.'}, 'description': {'type': 'string', 'description': 'New description for the spec. Omit to keep the current value.'}, 'runAnalysis': {'type': 'boolean', 'description': 'Whether to run analysis and wait for it after saving the changes (default true). Only applies to the synchronous (no-file-change) path.'}, 'workspaceId': {'type': 'string', 'description': 'Workspace to act on. Defaults to your only workspace if you have exactly one.'}, 'sourceTables': {'type': 'array', 'items': {'type': 'string'}, 'description': 'sourceType "tables" specs only: replacement list of source tables the generated query reads from.'}, 'targetOption': {'enum': ['auto-infer', 'existing-tables', 'target-schema-file'], 'type': 'string', 'description': 'Change where transformed data lands. Omit to keep the current setting.'}, 'targetTables': {'type': 'array', 'items': {'type': 'string'}, 'description': 'sourceType "file" specs: new list of existing workspace tables to load into. Required when setting targetOption to "existing-tables". sourceType "tables" specs: the query\'s single target table name — pass a one-element array to rename the target (its schema is re-resolved per the spec\'s targetOption).'}, 'formatFileName': {'type': 'string', 'description': 'sourceType "file" specs only. File name of a replacement format spec file, if replacing it.'}, 'loadSampleData': {'type': 'boolean', 'description': 'Whether re-analysis should also trigger the data-load job (default true). Only used when runAnalysis is true.'}, 'sampleFileName': {'type': 'string', 'description': 'sourceType "file" specs only. File name of a replacement sample data file, if replacing it.'}, 'additionalPrompt': {'type': 'string', 'description': "Extra natural-language guidance for the AI schema inference/mapping. Replaces the previously stored value when given (omit to keep it as-is), and is reused on every future re-analysis — keep it to instructions that actually change behavior. Don't restate default platform behavior (e.g. that unmapped target columns are null on insert and preserved on merge match) just to document it; a note only true for one case (like new rows) can read as a standing instruction later and confuse updates."}, 'targetSchemaFileName': {'type': 'string', 'description': 'File name of a replacement target schema file. Required when setting targetOption to "target-schema-file".'}}, 'additionalProperties': False}
Output schema
{'type': 'object', '$schema': 'http://json-schema.org/draft-07/schema#', 'required': ['message'], 'properties': {'error': {'type': ['string', 'null']}, 'files': {'type': 'array', 'items': {'type': 'object', 'required': ['fileName', 'url', 'contentType'], 'properties': {'url': {'type': 'string'}, 'fileName': {'type': 'string'}, 'contentType': {'type': 'string'}}, 'additionalProperties': False}, 'description': 'Present only when replacement file(s) were given — upload these, then call finish_data_spec_update.'}, 'specId': {'type': 'string'}, 'status': {'type': 'string'}, 'message': {'type': 'string'}, 'nextStep': {'type': 'string', 'description': 'The finish_data_spec_update call to make once upload(s) are done. Only present alongside files.'}, 'progress': {'type': 'number'}, 'specName': {'type': 'string'}, 'timedOut': {'type': 'boolean'}, 'lastJobId': {'type': ['string', 'null']}, 'errorDetails': {'type': ['string', 'null']}, 'statusMessage': {'type': 'string'}, 'hasTransformationConfig': {'type': 'boolean'}}, 'additionalProperties': False}
History
Recent tool changes
Added
contact
Sept. 17, 2026, 12:34 p.m.
Added
manage_account
Sept. 17, 2026, 12:34 p.m.
Added
call_dpf_api
Sept. 17, 2026, 12:34 p.m.
Added
setup_scheduled_pull
Sept. 17, 2026, 12:34 p.m.
Added
finish_data_job
Sept. 17, 2026, 12:34 p.m.
Added
run_data_job
Sept. 17, 2026, 12:34 p.m.
Added
finish_data_spec_update
Sept. 17, 2026, 12:34 p.m.
Added
update_data_spec
Sept. 17, 2026, 12:34 p.m.
Added
finish_data_source_onboarding
Sept. 17, 2026, 12:34 p.m.
Added
onboard_data_source
Sept. 17, 2026, 12:34 p.m.
Added
manage_trigger
Sept. 17, 2026, 12:34 p.m.
Added
manage_connection
Sept. 17, 2026, 12:34 p.m.
Added
submit_query
Sept. 17, 2026, 12:34 p.m.
Added
delete_data_spec
Sept. 17, 2026, 12:34 p.m.
Added
get_status
Sept. 17, 2026, 12:34 p.m.
Added
list_data
Sept. 17, 2026, 12:34 p.m.
Added
create_workspace
Sept. 17, 2026, 12:34 p.m.
Added
list_my_workspaces
Sept. 17, 2026, 12:34 p.m.
Discover
Similar MCP servers
Scalix Cloud
world.scalix/cloud
Provides managed databases, SQL tools, container builds, persistent Linux machines, domains, scheduled functions, storage, and pr…
RationalBloks
io.github.rationalbloks/rationalbloks-mcp
Creates, deploys, manages, and searches schema-based REST API projects and Neo4j knowledge graphs across staging and production e…
RationalBloks
com.rationalbloks/mcp
Creates, deploys, manages, and queries REST API and Neo4j graph projects from JSON schemas, including graph data modeling, versio…
Supabase
io.github.mcp-dir/supabase-mcp
Manages Supabase projects, PostgreSQL databases, migrations, branches, storage-related infrastructure, Edge Functions, logs, keys…
Databricks
io.github.mcp-dir/databricks-mcp
Connects to Databricks workspaces to browse Unity Catalog metadata, execute SQL, inspect tables and warehouses, and manage long-r…
mcp
com.googleapis.bigtableadmin/mcp
Manages Google Cloud Bigtable instances, tables, logical views, and hot-tablet monitoring.
mcp
com.googleapis.datastream/mcp
Manages Google Cloud Datastream resources, including streams, connection profiles, stream objects, static IPs, and long-running o…
site
com.rmmcompare/site
Provides searchable and statistical access to an RMM software comparison dataset and submits consent-based enquiries to human pro…