{"name":"com.dpf-it/mcp-server","slug":"dpf-it-mcp-server","title":null,"description":"AI-powered data integration platform. Onboard users and run DPF data workflows.","url":"https://mcp.market/server/dpf-it-mcp-server","rating":null,"grade":"C","score":55,"certified":false,"status":"active","category":"other","tags":[],"presence":{"score":5,"stars":null,"forks":null,"downloads_week":null,"last_push_at":null,"license":null},"uptime":{"percent":100,"checks":28,"ok":28,"last_checked_at":"2026-09-27T14:30:49.103Z","last_ok_at":"2026-09-27T14:30:49.103Z","latency_ms":975},"claimed":false,"transport":"remote","callable_via_gateway":true,"default_price_micros":0,"repository":null,"website":null,"version":"1.0.0","remotes":[{"type":"streamable-http","url":"https://api.dpf-it.com/mcp"}],"packages":[],"tools":[{"name":"call_dpf_api","description":"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).","write_action":false,"price_micros":0,"input_schema":{"type":"object","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\"."},"workspaceId":{"type":"string","description":"Include for workspace-scoped actions. Omit entirely for account-level actions."},"params":{"type":"object","additionalProperties":{},"description":"Additional action-specific fields to merge into the request body alongside action/workspaceId."}},"required":["path","action"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"contact","description":"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.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"reason":{"type":"string","enum":["request-a-demo","understand-licensing","report-an-issue","request-a-feature"]},"message":{"type":"string","minLength":1,"maxLength":5000},"email":{"type":"string","format":"email","description":"The sender's email address, so DPF can reply."},"name":{"type":"string"}},"required":["reason","message","email"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"create_workspace","description":"Create a new workspace, owned by the authenticated user. Use this if list_my_workspaces returns none.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"name":{"type":"string","description":"Workspace name"},"description":{"type":"string","description":"Optional workspace description."}},"required":["name"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"delete_data_spec","description":"Permanently delete a data spec and its associated configuration.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"specName":{"type":"string","description":"Name of the data spec to delete."}},"required":["specName"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"finish_data_job","description":"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.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"jobId":{"type":"string","description":"jobId returned by run_data_job."},"specName":{"type":"string","description":"Name of the data spec this job belongs to."}},"required":["jobId","specName"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"finish_data_source_onboarding","description":"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.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"specId":{"type":"string","description":"specId returned by onboard_data_source."},"specName":{"type":"string","description":"Name of the data spec being onboarded."},"loadSampleData":{"type":"boolean","description":"Whether to load the sample file and trigger the data-load job once analysis finishes (default true)."}},"required":["specId","specName"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"finish_data_spec_update","description":"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.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"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."},"loadSampleData":{"type":"boolean","description":"Whether analysis should also trigger the data-load job (default true)."}},"required":["specId","specName"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"get_status","description":"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.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"specId":{"type":"string","description":"Poll a data spec's analysis status. Pass exactly one of specId or jobId."},"jobId":{"type":"string","description":"Poll a data-load job's status. Pass exactly one of specId or jobId."}},"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"list_data","description":"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.\n\nThis 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.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"resource":{"type":"string","enum":["specs","jobs"],"description":"Which kind of resource to list"},"pageSize":{"type":"integer","minimum":1,"maximum":100,"description":"Records per page (default 25)."},"cursor":{"type":"string","description":"Opaque `nextCursor` from a prior page (omit for the first page)."}},"required":["resource"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"list_my_workspaces","description":"List every workspace the authenticated user has access to, including their permission on each.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{},"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"manage_account","description":"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).","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"action":{"type":"string","enum":["register","verify","resend","forgot-password","reset-password"]},"email":{"type":"string","format":"email"},"firstName":{"type":"string","description":"action \"register\" only"},"lastName":{"type":"string","description":"action \"register\" only"},"termsAccepted":{"type":"boolean","description":"action \"register\" only. Must be true."},"otp":{"type":"string","pattern":"^\\d{6}$","description":"action \"verify\" and \"reset-password\" only. The 6-digit code from the email DPF sent."}},"required":["action","email"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"manage_connection","description":"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.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"action":{"type":"string","enum":["create","list","test","delete"],"description":"Which operation to perform."},"type":{"type":"string","enum":["sftp","aws_s3"],"description":"Connection type. Required for create; defaults to \"sftp\"."},"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\"."},"roleArn":{"type":"string","description":"aws_s3 only. The IAM role the customer will create/update. Required for create."},"connectionId":{"type":"string","description":"Existing connection to test or delete. Required for test/delete."}},"required":["action"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"manage_trigger","description":"Create, list, update, delete, or fire a workspace job trigger. Four types:\n- \"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.\n- \"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\").\n- \"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\").\n\nIMPORTANT: \"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).\n\nAfter 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`.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"action":{"type":"string","enum":["create","list","update","delete","run-now","clear-processed-files","run-history"],"description":"Which operation to perform."},"triggerId":{"type":"string","description":"Existing trigger. Required for update/delete/run-now/clear-processed-files."},"specName":{"type":"string","description":"The spec this trigger fires. Required for create."},"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."},"type":{"type":"string","enum":["sftp","aws_s3","spec_success","schedule"],"description":"Trigger type. Optional for create (defaults to \"sftp\"). For sftp/aws_s3 must match the connection's type."},"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."},"frequency":{"type":"object","properties":{"unit":{"type":"string","enum":["hourly","daily","monthly"],"description":"Schedule cadence."},"hourOfDay":{"type":"integer","minimum":0,"maximum":23,"description":"Required for daily/monthly (UTC)."},"dayOfMonth":{"type":"integer","minimum":1,"maximum":31,"description":"Required for monthly."}},"required":["unit"],"additionalProperties":false,"description":"Required for create when type is \"sftp\", \"aws_s3\", or \"schedule\"; optional on update to change the schedule. Not applicable to spec_success."},"upstreamSpecName":{"type":"string","description":"spec_success only. The spec whose successful job completion fires this trigger. Required for create when type is \"spec_success\"."},"preRules":{"type":"string","description":"sftp/aws_s3 only. Natural language: which files to pick up (e.g. \"only *.csv under /outbound\")."},"postRules":{"type":"string","description":"sftp/aws_s3 only. Natural language: what to do after a file loads (e.g. \"rename with .done suffix\")."},"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."},"enabled":{"type":"boolean","description":"Whether the trigger is active. Defaults to true on create."},"specId":{"type":"string","description":"run-history: filter to runs of triggers feeding this spec."},"pageSize":{"type":"integer","minimum":1,"maximum":100,"description":"run-history: records per page (default 25)."},"cursor":{"type":"string","description":"run-history: opaque `nextCursor` from a prior page (omit for the first page)."},"startTime":{"type":"string","description":"run-history: ISO 8601 lower bound (inclusive) on when the run started."},"endTime":{"type":"string","description":"run-history: ISO 8601 upper bound (inclusive) on when the run started."}},"required":["action"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"onboard_data_source","description":"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.\n\nUse 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.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"specName":{"type":"string","description":"Name for the new data spec."},"description":{"type":"string","description":"Optional description of the data spec."},"sourceType":{"type":"string","enum":["file","tables","compaction"],"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."},"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)."},"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."},"targetOption":{"type":"string","enum":["auto-infer","existing-tables","target-schema-file"],"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."},"targetSchemaFileName":{"type":"string","description":"File name of a target schema file. Required when targetOption is \"target-schema-file\", for either sourceType."},"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."},"formatFileName":{"type":"string","description":"sourceType \"file\" only. File name of an optional format spec file."},"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."},"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."},"autoRefresh":{"type":"string","enum":["spec_success","schedule","none"],"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)."},"autoRefreshUpstreamSpecName":{"type":"string","description":"Required when autoRefresh is \"spec_success\". The spec whose successful job completion should re-run this one."},"autoRefreshFrequency":{"type":"object","properties":{"unit":{"type":"string","enum":["hourly","daily","monthly"],"description":"Schedule cadence."},"hourOfDay":{"type":"integer","minimum":0,"maximum":23,"description":"Required for daily/monthly (UTC)."},"dayOfMonth":{"type":"integer","minimum":1,"maximum":31,"description":"Required for monthly."}},"required":["unit"],"additionalProperties":false,"description":"Required when autoRefresh is \"schedule\"."}},"required":["specName"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"run_data_job","description":"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.\n\nDo 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).","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"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\"])"}},"required":["specName","fileNames"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"setup_scheduled_pull","description":"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.","write_action":false,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"hostname":{"type":"string","description":"sftp: SFTP server hostname to pull from."},"username":{"type":"string","description":"sftp only. Defaults to \"sftpuser\"."},"roleArn":{"type":"string","description":"aws_s3: the IAM role the customer will create/update."},"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)"},"frequency":{"type":"object","properties":{"unit":{"type":"string","enum":["hourly","daily","monthly"],"description":"Schedule cadence."},"hourOfDay":{"type":"integer","minimum":0,"maximum":23,"description":"Required for daily/monthly (UTC)."},"dayOfMonth":{"type":"integer","minimum":1,"maximum":31,"description":"Required for monthly."}},"required":["unit"],"additionalProperties":false,"description":"Pull schedule."},"preRules":{"type":"string","description":"Natural language: which files to pick up (e.g. \"only *.csv under /outbound\")"},"postRules":{"type":"string","description":"Natural language: what to do after a file loads (e.g. \"rename with .done suffix\")"},"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."}},"required":["specName","frequency"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"submit_query","description":"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.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"sql":{"type":"string","description":"SQL query, e.g. SELECT * FROM customers LIMIT 10"}},"required":["sql"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}},{"name":"update_data_spec","description":"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.","write_action":true,"price_micros":0,"input_schema":{"type":"object","properties":{"workspaceId":{"type":"string","description":"Workspace to act on. Defaults to your only workspace if you have exactly one."},"specName":{"type":"string","description":"Name of the existing data spec to update"},"description":{"type":"string","description":"New description for the spec. Omit to keep the current value."},"targetOption":{"type":"string","enum":["auto-infer","existing-tables","target-schema-file"],"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)."},"targetSchemaFileName":{"type":"string","description":"File name of a replacement target schema file. Required when setting targetOption to \"target-schema-file\"."},"sampleFileName":{"type":"string","description":"sourceType \"file\" specs only. File name of a replacement sample data file, if replacing it."},"formatFileName":{"type":"string","description":"sourceType \"file\" specs only. File name of a replacement format spec file, if replacing it."},"sourceTables":{"type":"array","items":{"type":"string"},"description":"sourceType \"tables\" specs only: replacement list of source tables the generated query reads from."},"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."},"computeSize":{"type":"string","enum":["small","large"],"description":"Compute size for analysis/processing. Omit to keep the current setting."},"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."},"loadSampleData":{"type":"boolean","description":"Whether re-analysis should also trigger the data-load job (default true). Only used when runAnalysis is true."},"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."}},"required":["specName"],"additionalProperties":false,"$schema":"http://json-schema.org/draft-07/schema#"}}],"scan":{"score":55,"grade":"C","scanned_at":"2026-09-24T21:41:22.273Z","report":{"scannerVersion":"0.1.9","scannedAt":"2026-09-24T21:41:22.262Z","components":{"code":{"score":-1,"max":25,"notes":["remote-only server, no package to scan"]},"reliability":{"score":20,"max":20,"notes":["remote reachable in 534ms"]},"poisoning":{"score":13,"max":15,"notes":["18 tool descriptions checked"]},"auth":{"score":3,"max":15,"notes":["open endpoint exposes 9 write-action tools with no auth"]},"maintenance":{"score":3,"max":15,"notes":["no repository listed"]},"identity":{"score":2,"max":10,"notes":["no repository or website to verify"]}},"findings":[{"id":"auth.open-write","severity":"high","component":"auth","title":"Write-action tools reachable without authentication"},{"id":"poison.long-description","severity":"low","component":"poisoning","title":"Unusually long tool description (over 2,000 characters)","evidence":"tool manage_trigger: …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`.…"},{"id":"maint.no-repo","severity":"low","component":"maintenance","title":"No source repository listed"}],"inputs":{"probes":[{"url":"https://api.dpf-it.com/mcp","reachable":true,"authRequired":false,"latencyMs":534,"serverInfo":{"name":"dpf-mcp-remote","version":"1.0.0"}}],"packages":[],"repo":{"found":false},"icon":{"url":"https://dpf-it.com/favicon.svg","source":"site"},"presence":{"stars":null,"forks":null,"downloadsWeek":null,"license":null,"lastPushAt":null,"score":5}}}},"grade_history":[],"reviews":[]}