Integration

Turbot Pipes integration

Turbot Pipes is a hosted platform for Steampipe, Powerpipe and Flowpipe: it queries cloud and SaaS APIs (AWS, Azure, GitHub and more) with SQL. Run a SQL query against a workspace, manage organizations, workspaces and their members, create and test connections (plugin credentials) and manage who may use them, list a schema's tables and their columns, install mods, take and manage snapshots, schedule pipelines and inspect the processes they run. Not exposed: tenant administration, billing, avatars, API and service-account tokens, database passwords, AI keys and conversations, integrations, datatanks, notifiers, Flowpipe forms, deprecated conn routes, every read, update, delete or workspace attachment of an existing connection or schema (those answers carry the connection's stored credentials), raw-body and CSV or Markdown query variants, and file downloads. Authentication is a Pipes API token sent as a Bearer token.

Connect Turbot Pipes How integrations work

Ask it in chat

Say what should happen.
The workflow builds itself.

When this happens, do that in Turbot Pipes.Built from the 102 Turbot Pipes tools below, on the connection you add once.

What you can do with Turbot Pipes

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.

Workspace, 11 operations

create_org_workspaceCreate org workspacePOSTCreates a new workspace for an organization. The limit is 10 per organization. If you require more than 10, you must contact support to request an increase.
create_user_workspaceCreate user workspacePOSTCreates a new workspace for a user.
delete_org_workspaceDelete org workspaceDELETEDeletes the workspace specified in the request.
delete_user_workspaceDelete user workspaceDELETEDeletes the workspace specified in the request by the user.
get_org_workspaceGet org workspaceGETGet the details for a workspace in an organization.
get_user_workspaceGet user workspaceGETGet the details for the workspace.
list_actor_workspacesList actor workspacesGETLists every workspace the token's user can access, across their own account and organizations.
list_org_workspacesList org workspacesGETLists the workspaces of a org, each with its handle, state, database instance and host.
list_user_workspacesList user workspacesGETLists the workspaces of a user, each with its handle, state, database instance and host.
update_org_workspaceUpdate org workspacePATCHUpdates an org workspace: handle, desired state, instance type, volume size or search path. Leave out to keep the current value.
update_user_workspaceUpdate user workspacePATCHUpdates a user workspace: handle, desired state, instance type, volume size or search path. Leave out to keep the current value.

Member, 10 operations

create_org_memberCreate org memberPOSTAdd a user as a member of an org in a custom tenant.
create_org_workspace_memberCreate org workspace memberPOSTAdd an individual as a member of a workspace in an organization.
delete_org_memberDelete org memberDELETERemoves a user from an organization.
delete_org_workspace_memberDelete org workspace memberDELETERemove a member from a workspace of an organization.
get_org_memberGet org memberGETGets a member of an organization with their role and status.
get_org_workspace_memberGet org workspace memberGETGet details of a member belonging to a workspace of an organization.
list_org_membersList org membersGETList all members of an organization who are invited / accepted.
list_org_workspace_membersList org workspace membersGETList all members of a workspace in an organization who has accepted / invited.
update_org_memberUpdate org memberPATCHChanges the role of an organization member.
update_org_workspace_memberUpdate org workspace memberPATCHUpdate the role of a member belonging to a workspace of an organization.

Mod, 10 operations

get_org_workspace_modGet org workspace modGETGet organization workspace installed mod by mod alias
get_user_workspace_modGet user workspace modGETGet user workspace installed mod by mod alias
install_org_workspace_modInstall org workspace modPOSTInstalls a mod (Powerpipe benchmarks and dashboards from a Git repository) into an org workspace.
install_user_workspace_modInstall user workspace modPOSTInstalls a mod (Powerpipe benchmarks and dashboards from a Git repository) into a user workspace.
list_org_workspace_modsList org workspace modsGETLists the mods (Powerpipe benchmarks and dashboards) installed in an org workspace.
list_user_workspace_modsList user workspace modsGETLists the mods (Powerpipe benchmarks and dashboards) installed in a user workspace.
uninstall_org_workspace_modUninstall org workspace modDELETEUninstalls a mod from an org workspace.
uninstall_user_workspace_modUninstall user workspace modDELETEUninstalls a mod from a user workspace.
update_org_workspace_modUpdate org workspace modPATCHUpdates a mod installed in an org workspace, for example to another version or branch.
update_user_workspace_modUpdate user workspace modPATCHUpdates a mod installed in a user workspace, for example to another version or branch.

Pipeline, 10 operations

create_org_workspace_pipelineCreate org workspace pipelinePOSTCreates a pipeline in an org workspace: a scheduled job that snapshots a dashboard or a query (pipeline.snapshot_dashboard or pipeline.snapshot_query) at an interval or cron schedule.
create_user_workspace_pipelineCreate user workspace pipelinePOSTCreates a pipeline in a user workspace: a scheduled job that snapshots a dashboard or a query (pipeline.snapshot_dashboard or pipeline.snapshot_query) at an interval or cron schedule.
delete_org_workspace_pipelineDelete org workspace pipelineDELETEDeletes the pipeline specified in the request for a workspace of an organization.
delete_user_workspace_pipelineDelete user workspace pipelineDELETEDeletes the pipeline specified in the request for a workspace of a user.
get_org_workspace_pipelineGet org workspace pipelineGETGet the details of a pipeline for a workspace of an organization.
get_user_workspace_pipelineGet user workspace pipelineGETGet the details of a pipeline for a workspace of a user.
list_org_workspace_pipelinesList org workspace pipelinesGETLists the pipelines for a workspace of an organization.
list_user_workspace_pipelinesList user workspace pipelinesGETLists the pipelines for a workspace of a user.
update_org_workspace_pipelineUpdate org workspace pipelinePATCHUpdates a pipeline for a workspace of an organization.
update_user_workspace_pipelineUpdate user workspace pipelinePATCHUpdates a pipeline for a workspace of a user.

Snapshot, 10 operations

create_org_workspace_snapshotCreate org workspace snapshotPOSTSaves a snapshot (a Powerpipe or Steampipe result document) in an org workspace.
create_user_workspace_snapshotCreate user workspace snapshotPOSTSaves a snapshot (a Powerpipe or Steampipe result document) in a user workspace.
delete_org_workspace_snapshotDelete org workspace snapshotDELETEDeletes an org workspace snapshot.
delete_user_workspace_snapshotDelete user workspace snapshotDELETEDeletes a user workspace snapshot.
get_org_workspace_snapshotGet org workspace snapshotGETGet the details for an org workspace snapshot.
get_user_workspace_snapshotGet user workspace snapshotGETGet the details for a user workspace snapshot.
list_org_workspace_snapshotsList org workspace snapshotsGETLists the snapshots (saved dashboard or query results) of an org workspace.
list_user_workspace_snapshotsList user workspace snapshotsGETLists the snapshots (saved dashboard or query results) of a user workspace.
update_org_workspace_snapshotUpdate org workspace snapshotPATCHUpdates an org workspace snapshot's title, tags or visibility.
update_user_workspace_snapshotUpdate user workspace snapshotPATCHUpdates a user workspace snapshot's title, tags or visibility.

Command, 6 operations

run_org_workspace_commandRun org workspace commandPOSTRuns a command on an org workspace. The only valid command is reboot, which restarts the workspace database.
run_org_workspace_pipeline_commandRun org workspace pipeline commandPOSTRuns an org workspace pipeline now (command run), outside its schedule.
run_org_workspace_process_commandRun org workspace process commandPOSTRuns a command against an org workspace process (a pipeline run or update job). The vendor's reference does not list the accepted commands.
run_user_workspace_commandRun user workspace commandPOSTRuns a command on a user workspace. The only valid command is reboot, which restarts the workspace database.
run_user_workspace_pipeline_commandRun user workspace pipeline commandPOSTRuns a user workspace pipeline now (command run), outside its schedule.
run_user_workspace_process_commandRun user workspace process commandPOSTRuns a command against a user workspace process (a pipeline run or update job). The vendor's reference does not list the accepted commands.

Org, 6 operations

create_orgCreate orgPOSTCreates an organization. Workspaces, connections and members can then be added to it.
delete_orgDelete orgDELETEDeletes the specified organization if you have the appropriate access.
get_orgGet orgGETGets an organization: handle, display name, URL and usage settings.
list_actor_orgsList actor orgsGETLists the organizations the token's user belongs to.
list_orgsList orgsGETLists the organizations visible to the token's user.
update_orgUpdate orgPATCHUpdates an organization's handle, display name, URL or usage thresholds. Leave out to keep the current value.

Permission, 5 operations

create_org_connection_permissionCreate org connection permissionPOSTCreate permissions for a connection defined on an org.
delete_org_connection_permissionDelete org connection permissionDELETEDelete permission for a connection defined on an org.
get_org_connection_permissionGet org connection permissionGETGet permission for a connection defined on an org.
list_org_connection_permissionsList org connection permissionsGETList permissions for a connection defined on an org.
update_org_connection_permissionUpdate org connection permissionPATCHUpdate permission for a connection defined on an org.

Audit log, 4 operations

list_org_audit_logsList org audit logsGETReturns the audit logs of an organization: who changed what, and when.
list_org_workspace_audit_logsList org workspace audit logsGETReturns the audit logs of an org workspace: who changed what, and when.
list_user_audit_logsList user audit logsGETReturns the audit logs of a user account: who changed what, and when.
list_user_workspace_audit_logsList user workspace audit logsGETReturns the audit logs of a user workspace: who changed what, and when.

Process, 4 operations

get_org_workspace_processGet org workspace processGETGets one process of an org workspace (a pipeline run or update job), with its type and state.
get_user_workspace_processGet user workspace processGETGets one process of a user workspace (a pipeline run or update job), with its type and state.
list_org_workspace_processesList org workspace processesGETList the processes associated with an org workspace.
list_user_workspace_processesList user workspace processesGETList the process associated with a user workspace.

Table, 4 operations

get_org_workspace_schema_tableGet org workspace schema tableGETGet details about a specific table in a org workspace schema.
get_user_workspace_schema_tableGet user workspace schema tableGETGet details about a specific table in a user workspace schema.
list_org_workspace_schema_tablesList org workspace schema tablesGETLists the tables of a schema in an org workspace, to know what can be queried with query_org_workspace.
list_user_workspace_schema_tablesList user workspace schema tablesGETLists the tables of a schema in a user workspace, to know what can be queried with query_user_workspace.

Test, 4 operations

test_org_connectionTest org connectionPOSTTest the config for an org connection to check for basic connectivity before you create it.
test_org_workspace_connectionTest org workspace connectionPOSTTest the config for a connection configured on an org workspace to check for basic connectivity.
test_user_connectionTest user connectionPOSTTest the config for a user connection to check for basic connectivity.
test_user_workspace_connectionTest user workspace connectionPOSTTest the config for a connection configured on a user workspace to check for basic connectivity.

Invite, 3 operations

delete_org_member_inviteDelete org member inviteDELETECancels a pending invitation to an organization.
invite_org_memberInvite org memberPOSTInvites a person to an organization by email or user handle, with a role.
list_actor_org_invitesList actor org invitesGETLists pending organization invitations for the token's user.

User, 3 operations

get_userGet userGETGets a user by handle: display name, URL, status and usage settings.
list_usersList usersGETLists the users visible to the token's user.
update_userUpdate userPATCHUpdates the handle name, display name, or the URL of a user.

Connection, 2 operations

create_org_connectionCreate org connectionPOSTCreates a new connection for an organization.
create_user_connectionCreate user connectionPOSTCreates a connection (a Steampipe plugin with its credentials) for a user. Check the credentials first with test_user_connection.

Constraint, 2 operations

list_org_constraintsList org constraintsGETLists the limits (constraints) that apply to an organization.
list_user_constraintsList user constraintsGETLists the limits (constraints) that apply to a user account.

Db log, 2 operations

list_org_workspace_db_logsList org workspace db logsGETReturns the database query logs of an org workspace: the SQL queries run against it.
list_user_workspace_db_logsList user workspace db logsGETReturns the database query logs of a user workspace: the SQL queries run against it.

Query, 2 operations

query_org_workspaceQuery org workspaceGETRuns a SQL query against an org workspace's Steampipe database and returns the rows as JSON. Results are limited to 5000 rows or 30 seconds of execution.
query_user_workspaceQuery user workspaceGETRuns a SQL query against a user workspace's Steampipe database and returns the rows as JSON. Results are limited to 5000 rows or 30 seconds of execution.

Usage, 2 operations

list_org_usageList org usageGETLists the usage metrics of an organization (compute, storage, users).
list_user_usageList user usageGETLists the usage metrics of a user account (compute, storage).

Activity, 1 operation

list_actor_activityList actor activityGETLists recent activity of the user the API token belongs to.

Actor, 1 operation

get_actorGet actorGETReturns the user the API token belongs to (handle, display name, status). Use its handle as user_handle in the user tools.

Use Turbot Pipes from Claude Code, Cursor or Codex

Connect Turbot Pipes in LiveContext, create an API key in Settings, then add the LiveContext MCP server to your client. Its Turbot Pipes 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 Turbot Pipes

Create your workspace
Sign up free. Nothing to install.
Connect Turbot Pipes once
Add your Turbot Pipes 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.