Integration

Windmill integration

Windmill turns scripts (Python, TypeScript, Go, Bash, SQL) and flows into internal apps, APIs and scheduled jobs. This integration covers the read and run surface of a Windmill instance: run a script or a flow by path, hash or version and wait for its result, follow a job's progress, list and count queued and completed jobs and read their results, timings, arguments and logs, browse scripts, flows, apps and raw apps with their versions, history and deployment status, read resources, resource types and their values, variables and contextual variables, schedules, folders, groups, users and workspaces, read audit logs, drafts, saved inputs, flow conversations and capture payloads, list HTTP, websocket, Kafka, NATS, MQTT, SQS, GCP, Postgres, AMQP, Azure and email triggers and their history, browse the public Windmill Hub for scripts, flows, apps and integrations, and manage workspace object storage files (upload, download, move, delete, list, preview metadata, storage usage). Note that Windmill answers most create, update and delete calls with a plain-text body (the new path, hash or job id), which this catalog cannot decode, so those routes are not exposed here. The host is part of the credential because every install is its own deployment (Windmill Cloud users point it at app.windmill.dev). Authentication is a Windmill token sent as a bearer token in the Authorization header.

Connect Windmill How integrations work

Ask it in chat

Say what should happen.
The workflow builds itself.

When this happens, do that in Windmill.Built from the 220 Windmill tools below, on the connection you add once.

What you can do with Windmill

Each of these is one operation on one endpoint, available both as a workflow step and as a tool an AI agent can call on its own. Nothing bundles several operations into one action, so what a run did stays readable afterwards.

Most endpoints run on the free plan. A few, mainly the ones that publish on your behalf, need a paid plan.

Get, 30 operations

get_amqp_triggerGet amqp triggerGETget amqp trigger.
get_audit_logGet audit logGETget audit log (requires admin privilege).
get_azure_triggerGet azure triggerGETget an Azure Event Grid trigger.
get_completed_jobGet completed jobGETget completed job.
get_draftGet draftGETfetch a single draft's content by workspace username (or the legacy workspace-level row).
get_email_triggerGet email triggerGETget email trigger.
get_flow_by_pathGet flow by pathGETget flow by path.
get_folderGet folderGETget folder.
get_folder_historyGet folder historyGETget folder permission history.
get_gcp_triggerGet gcp triggerGETget gcp trigger.
get_group_historyGet group historyGETget group permission history.
get_http_triggerGet http triggerGETget http trigger.
get_hub_appGet hub appGETget hub app by id.
get_hub_flowGet hub flowGETget hub flow by id.
get_instance_groupGet instance groupGETget instance group.
get_jobGet jobGETget job.
get_job_metricsGet job metricsPOSTget job metrics.
get_kafka_triggerGet kafka triggerGETget kafka trigger.
get_mqtt_triggerGet mqtt triggerGETget mqtt trigger.
get_nats_triggerGet nats triggerGETget nats trigger.
get_postgres_publicationGet postgres publicationGETget postgres publication.
get_postgres_triggerGet postgres triggerGETget postgres trigger.
get_resourceGet resourceGETget resource.
get_resource_typeGet resource typeGETget resource_type.
get_scheduleGet scheduleGETget schedule.
get_sqs_triggerGet sqs triggerGETget sqs trigger.
get_variableGet variableGETget variable.
get_websocket_triggerGet websocket triggerGETget websocket trigger.
get_workspace_groupGet workspace groupGETget group.
get_workspace_userGet workspace userGETget user (require admin privilege).

Exist, 10 operations

amqp_trigger_existsAmqp trigger existsGETdoes amqp trigger exists.
app_existsApp existsGETdoes an app exisst at path.
azure_trigger_existsAzure trigger existsGETcheck whether an azure trigger exists.
email_existsEmail existsGETexists email.
email_trigger_existsEmail trigger existsGETdoes email trigger exists.
flow_existsFlow existsGETexists flow by path.
folder_existsFolder existsGETexists folder.
gcp_trigger_existsGcp trigger existsGETdoes gcp trigger exists.
http_trigger_existsHttp trigger existsGETdoes http trigger exists.
kafka_trigger_existsKafka trigger existsGETdoes kafka trigger exists.

List, 9 operations

list_amqp_triggersList amqp triggersGETlist amqp triggers.
list_appsList appsGETlist all apps.
list_audit_logsList audit logsGETlist audit logs (requires admin privilege).
list_azure_basic_topicsList azure basic topicsPOSTlist Basic Event Grid topics + system topics the service principal can access.
list_azure_namespacesList azure namespacesPOSTlist Event Grid Namespaces the service principal can access.
list_azure_namespace_subscriptionsList azure namespace subscriptionsPOSTlist subscriptions under a Namespace topic.
list_azure_namespace_topicsList azure namespace topicsPOSTlist topics under an Event Grid Namespace.
list_azure_triggersList azure triggersGETlist azure triggers.
list_capturesList capturesGETlist captures for a script or flow.

P, 5 operations

delete_script_by_pathDelete script by pathPOSTdelete script at a given path (require admin).
get_app_by_pathGet app by pathGETget app by path.
get_flow_deployment_statusGet flow deployment statusGETget flow deployment status.
get_script_by_pathGet script by pathGETget script by path.
list_app_historyList app historyGETget app history by path.

H, 4 operations

archive_script_by_hashArchive script by hashPOSTarchive script by hash.
delete_script_by_hashDelete script by hashPOSTdelete script by hash (erase content but keep hash, require admin).
get_script_by_hashGet script by hashGETget script by hash.
get_script_deployment_statusGet script deployment statusGETget script deployment status.

Delete bulk, 3 operations

delete_resources_bulkDelete resources bulkDELETEdelete resources in bulk.
delete_scripts_bulkDelete scripts bulkDELETEdelete scripts in bulk.
delete_variables_bulkDelete variables bulkDELETEdelete variables in bulk.

Get latest version, 3 operations

get_app_latest_versionGet app latest versionGETget apps's latest version.
get_flow_latest_versionGet flow latest versionGETget flow's latest version.
get_script_latest_versionGet script latest versionGETget scripts's latest version (hash).

V, 3 operations

get_app_by_versionGet app by versionGETget app by version.
get_flow_by_versionGet flow by versionGETget flow version.
get_resource_versionGet resource versionGETget a single resource version, with its value.

Capture, 2 operations

delete_captureDelete captureDELETEdelete a capture.
get_captureGet captureGETget a capture.

Count, 2 operations

count_completed_jobs_sinceCount completed jobs sinceGETget completed count.
count_queued_jobsCount queued jobsGETget queue count.

Get triggers count, 2 operations

count_flow_triggersCount flow triggersGETget triggers count of flow.
count_script_triggersCount script triggersGETget triggers count of script.

Get value, 2 operations

get_resource_valueGet resource valueGETget resource value.
get_variable_valueGet variable valueGETget variable value.

Whoami, 2 operations

get_my_global_userGet my global userGETget current global whoami (if logged in).
get_my_workspace_userGet my workspace userGETwhoami.

Arg, 1 operation

get_input_argsGet input argsGETGet args from history or saved input.

Cancel selection, 1 operation

cancel_selected_jobsCancel selected jobsPOSTcancel jobs based on the given uuids.

Cancel suspended trigger job, 1 operation

cancel_suspended_trigger_jobsCancel suspended trigger jobsPOSTcancel all suspended jobs for a specific trigger.

Commit offset, 1 operation

commit_kafka_trigger_offsetsCommit kafka trigger offsetsPOSTcommit kafka offsets for a specific trigger.

Count by tag, 1 operation

count_completed_jobs_by_tagCount completed jobs by tagGETCount jobs by tag.

Count job, 1 operation

count_completed_jobsCount completed jobsGETcount number of completed jobs with filter.

Custom path exist, 1 operation

app_custom_path_existsApp custom path existsGETcheck if custom path exists.

Delete s3 file, 1 operation

delete_workspace_fileDelete workspace fileDELETEPermanently delete file from S3.

Detailed, 1 operation

get_detailed_healthGet detailed healthGETdetailed health status.

Download s3 file, 1 operation

download_workspace_fileDownload workspace fileGETDownload file from S3 bucket.

Get arg, 1 operation

get_job_argsGet job argsGETget job args.

Get config, 1 operation

list_capture_configsList capture configsGETget capture configs for a script or flow.

Get flow all logs structured, 1 operation

get_flow_all_logsGet flow all logsGETget all logs for a flow job in a structured format.

Get flow all result, 1 operation

get_flow_all_resultsGet flow all resultsGETget statuses and truncated results for all jobs of a flow job's execution tree.

Get full, 1 operation

get_hub_scriptGet hub scriptGETget full hub script by path.

Get own, 1 operation

get_my_draftGet my draftGETfetch the current user's own draft content at a path (any kind).

Get progres, 1 operation

get_job_progressGet job progressGETget job progress.

Get raw, 1 operation

get_hub_app_rawGet hub app rawGETget hub raw app by id.

Get result, 1 operation

get_completed_job_resultGet completed job resultGETget completed job result.

Get result maybe, 1 operation

get_completed_job_result_if_readyGet completed job result if readyGETget completed job result if job is completed.

Get root job id, 1 operation

get_root_job_idGet root job idGETget root job id.

Get timing, 1 operation

get_completed_job_timingGet completed job timingGETget completed job timing.

Get value interpolated, 1 operation

get_interpolated_resource_valueGet interpolated resource valueGETget resource interpolated (variables and resources are fully unrolled).

Getusage, 1 operation

get_folder_usageGet folder usageGETget folder usage.

Is owner, 1 operation

is_owner_of_pathIs owner of pathGETis owner of path.

Is valid postgres configuration, 1 operation

is_valid_postgres_trigger_configIs valid postgres trigger configGETcheck if postgres configuration is set to logical.

Key, 1 operation

get_concurrency_group_keyGet concurrency group keyGETGet the concurrency key for a job that has concurrency limits enabled.

Lite, 1 operation

get_app_liteGet app liteGETget app lite by path.

Load file metadata, 1 operation

get_workspace_file_metadataGet workspace file metadataGETLoad metadata of the file.

Load file preview, 1 operation

get_workspace_file_previewGet workspace file previewGETLoad a preview of the file.

Local part exist, 1 operation

email_local_part_existsEmail local part existsPOSTdoes email local part exists.

Mcp call tool, 1 operation

call_resource_mcp_toolCall resource mcp toolPOSTcall a tool on the MCP server described by the resource.

Position, 1 operation

get_queue_positionGet queue positionGETget queue position for a job.

Result by id, 1 operation

get_flow_step_resultGet flow step resultGETget job result by id.

Resume url, 1 operation

get_job_resume_urlsGet job resume urlsGETget resume urls given a job_id, resume_id and a nonce to resume a flow.

Route exist, 1 operation

http_route_existsHttp route existsPOSTdoes route exists.

Run progres, 1 operation

get_job_run_progressGet job run progressGETList the per-relation progress one job has recorded so far.

Scheduled for, 1 operation

get_job_scheduled_forGet job scheduled forGETget scheduled for timestamp for a job.

Statu, 1 operation

get_health_statusGet health statusGEThealth status.

Storage usage, 1 operation

get_workspace_storage_usageGet workspace storage usageGETGet the storage usage of the workspace object storage, per configured storage. On Community Edition, also returns the workspace storage quota.

User state, 1 operation

get_flow_user_stateGet flow user stateGETget flow user state at a given key.

Version, 1 operation

get_postgres_versionGet postgres versionGETget postgres version.

Whoi, 1 operation

get_workspace_user_by_usernameGet workspace user by usernameGETwhois.

Showing the first 120 of 220 endpoints. The rest are in the product, searchable from the workflow builder and from chat.

Use Windmill from Claude Code, Cursor or Codex

Connect Windmill in LiveContext, create an API key in Settings, then add the LiveContext MCP server to your client. Its Windmill operations become tools the client can call, next to every other integration you connected.

Claude Code

claude mcp add --transport http livecontext https://livecontext.ai/mcp --header "X-API-Key: YOUR_API_KEY"

Codex (~/.codex/config.toml)

[mcp_servers.livecontext]
url = "https://livecontext.ai/mcp"

[mcp_servers.livecontext.http_headers]
"X-API-Key" = "YOUR_API_KEY"

Cursor, Claude Desktop and other JSON configs

{
  "mcpServers": {
    "livecontext": {
      "type": "http",
      "url": "https://livecontext.ai/mcp",
      "headers": {
        "X-API-Key": "YOUR_API_KEY"
      }
    }
  }
}

Set up the MCP server step by step

How to connect Windmill

Create your workspace
Sign up free. Nothing to install.
Connect Windmill once
Add your Windmill connection in Settings. Every tool from this integration reuses it, and secrets are encrypted at rest and visible only to you.
Describe the job in chat
The workflow builds itself in front of you and picks the endpoints it needs. Drag the steps yourself on the canvas whenever you would rather be explicit.