MCP server intelligence profile

DBOS MCP Server

Enables LLMs to analyze and manage DBOS workflows, including introspection, workflow management, and authentication, to help debug applications in development or production

Local OnlyOfficial distributiondbos-inc
Verified cleanPypi · 0.8.0

Our scanner tested version 0.8.0 without proving a finding in the methods exercised. This is not a guarantee that every deployment is secure.

1Distribution channel
25Independently observed tools
0Linked remote endpoints
AvailableVersion intelligence

Install and connect

Installation and connection instructions are shown only when supported by retained package, repository, or endpoint evidence.

Install dbos-mcp from PyPI

Install exact version 0.8.0. The executable name has not been verified, so it is intentionally not guessed.

python -m pip install 'dbos-mcp==0.8.0'

Identity

Canonical slugdbos-mcp-server-360fe1f2DeploymentLocal Only
Canonical packagepypi:dbos-mcpRepositorydbos-inc/dbos-mcp
First publishedAug 13, 2026Latest releaseAug 24, 2026
Last security verification—Classification confidence90%
PublicationPublishedOfficial distributionYes

Distributions

ChannelIdentifierCurrent versionVersionsSource
pypidbos-mcp0.8.02Repository

Current release

PackageVersionPublished / observedInventorySecurity scan
pypidbos-mcp0.8.0CurrentAug 24, 202625 toolsSucceeded · 0 resources · 0 promptsFailed
Enterprise protection

Continuously monitor this MCP for security risk

Independently scan the exact version your agents use, receive alerts when its risk changes, and investigate every finding with retained version evidence.

  • Independent exact-version security scans
  • Continuous release and vulnerability monitoring
  • Risk-change alerts with capability context
  • Historical evidence and API exports
Custom pricingContact salesTailored to your organization, integrations, data needs, and support requirements.

Current version evidence

Provenanceartifact_hash_verifiedSignature—
MCP SDK— Artifact SHA-25665587a2a3b7a36499f897a714e0b415c718c732cb7d50d7bd3be27b3041fc3b2
Scannermcp-proof-engine 0.1.0Scan completedAug 24, 2026
Security rating—Methodology—

Current protocol inventory

2025-06-18Negotiated protocol
dbos-conductorServer-reported name
4Capability groups
Aug 24, 2026Observed

Tools 25

ToolCategoryAnnotationsRisk
bulk_cancel_workflowsCancel multiple workflows at once. Sets each workflow's status to CANCELLED. Each workflow will stop executing at its next step boundary. Args: application_name (string, required): Name of the DBOS application workflow_ids (array of strings, required): IDs of the workflows to cancel cancel_children (bool, optional): Also cancel child workflows started by these workflows (default: false) Returns: message (string): Confirmation message count (int): Number of workflows cancelled
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_ids": {
      "items": {
        "type": "string"
      },
      "title": "Workflow Ids",
      "type": "array"
    },
    "cancel_children": {
      "default": false,
      "title": "Cancel Children",
      "type": "boolean"
    }
  },
  "required": [
    "application_name",
    "workflow_ids"
  ],
  "type": "object",
  "title": "bulk_cancel_workflowsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "bulk_cancel_workflowsDictOutput"
}
——
bulk_delete_workflowsDelete multiple workflows at once. Permanently deletes the workflows and their execution history. Args: application_name (string, required): Name of the DBOS application workflow_ids (array of strings, required): IDs of the workflows to delete delete_children (bool, optional): Also delete child workflows started by these workflows (default: false) Returns: message (string): Confirmation message count (int): Number of workflows deleted
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_ids": {
      "items": {
        "type": "string"
      },
      "title": "Workflow Ids",
      "type": "array"
    },
    "delete_children": {
      "default": false,
      "title": "Delete Children",
      "type": "boolean"
    }
  },
  "required": [
    "application_name",
    "workflow_ids"
  ],
  "type": "object",
  "title": "bulk_delete_workflowsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "bulk_delete_workflowsDictOutput"
}
——
bulk_resume_workflowsResume multiple workflows at once. Resumes execution of workflows that are in CANCELLED state. You can also use this on workflows in ENQUEUED state to immediately start them, bypassing their queue. Args: application_name (string, required): Name of the DBOS application workflow_ids (array of strings, required): IDs of the workflows to resume queue_name (string, optional): If provided, enqueue the resumed workflows onto this queue instead of running them immediately Returns: message (string): Confirmation message count (int): Number of workflows resumed
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_ids": {
      "items": {
        "type": "string"
      },
      "title": "Workflow Ids",
      "type": "array"
    },
    "queue_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Name"
    }
  },
  "required": [
    "application_name",
    "workflow_ids"
  ],
  "type": "object",
  "title": "bulk_resume_workflowsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "bulk_resume_workflowsDictOutput"
}
——
cancel_workflowCancel a running workflow. Sets the workflow status to CANCELLED. The workflow will stop executing at the next step boundary. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow to cancel cancel_children (bool, optional): Also cancel child workflows started by this workflow (default: false) Returns: message (string): Confirmation message workflow_id (string): The cancelled workflow ID
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    },
    "cancel_children": {
      "default": false,
      "title": "Cancel Children",
      "type": "boolean"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "cancel_workflowArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "cancel_workflowDictOutput"
}
——
delete_workflowDelete a workflow from DBOS Conductor. Permanently deletes a workflow and its execution history. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow to delete delete_children (bool, optional): Also delete child workflows started by this workflow (default: false) Returns: message (string): Confirmation message workflow_id (string): The deleted workflow ID
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    },
    "delete_children": {
      "default": false,
      "title": "Delete Children",
      "type": "boolean"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "delete_workflowArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "delete_workflowDictOutput"
}
——
fork_from_failureFork multiple failed workflows from a specific point. Creates new workflows that re-execute from a chosen point, reusing the recorded outputs of all prior steps. Useful for retrying a batch of failed workflows after deploying a fix. IMPORTANT: You must set exactly one of from_last_failure, from_last_step, from_step, or from_step_name. Args: application_name (string, required): Name of the DBOS application workflow_ids (array of strings, required): IDs of the workflows to fork application_version (string, optional): Application version for the new workflows (defaults to current version) queue_name (string, optional): Enqueue the forked workflows onto this queue queue_partition_key (string, optional): Partition key for the queue from_last_failure (bool, optional): Fork from the last failed step (default: false) from_last_step (bool, optional): Fork from the last executed step (default: false) from_step (int, optional): Fork from this specific step number from_step_name (string, optional): Fork from the step with this function name Returns: workflow_ids (array of strings): IDs of the newly created forked workflows count (int): Number of workflows forked
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_ids": {
      "items": {
        "type": "string"
      },
      "title": "Workflow Ids",
      "type": "array"
    },
    "application_version": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Application Version"
    },
    "queue_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Name"
    },
    "queue_partition_key": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Partition Key"
    },
    "from_last_failure": {
      "default": false,
      "title": "From Last Failure",
      "type": "boolean"
    },
    "from_last_step": {
      "default": false,
      "title": "From Last Step",
      "type": "boolean"
    },
    "from_step": {
      "anyOf": [
        {
          "type": "integer"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "From Step"
    },
    "from_step_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "From Step Name"
    }
  },
  "required": [
    "application_name",
    "workflow_ids"
  ],
  "type": "object",
  "title": "fork_from_failureArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "fork_from_failureDictOutput"
}
——
fork_workflowFork a workflow from a specific step. Creates a new workflow that starts from a specific step of an existing workflow, reusing the recorded outputs of all prior steps. Useful for debugging, testing fixes, or replaying workflows from a specific point. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow to fork from start_step (int, required): The step number to start from (use list_steps to find step IDs) application_version (string, optional): Application version for the new workflow (defaults to current version) new_workflow_id (string, optional): Custom ID for the new workflow (auto-generated if not specified) queue_name (string, optional): Enqueue the forked workflow onto this queue instead of running it immediately queue_partition_key (string, optional): Partition key for the queue Returns: workflow_id (string): The ID of the newly created forked workflow forked_from (string): The ID of the original workflow start_step (int): The step number the fork starts from
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    },
    "start_step": {
      "title": "Start Step",
      "type": "integer"
    },
    "application_version": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Application Version"
    },
    "new_workflow_id": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "New Workflow Id"
    },
    "queue_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Name"
    },
    "queue_partition_key": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Partition Key"
    }
  },
  "required": [
    "application_name",
    "workflow_id",
    "start_step"
  ],
  "type": "object",
  "title": "fork_workflowArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "fork_workflowDictOutput"
}
——
get_scheduleGet details of a specific schedule from DBOS Conductor. Args: application_name (string, required): Name of the DBOS application schedule_name (string, required): Name of the schedule Returns: scheduleId (string): Unique identifier scheduleName (string): Name of the schedule workflowName (string): The workflow function this schedule triggers workflowClass (string, optional): The workflow's class name, if any cronExpression (string): Cron expression defining the schedule status (string): "ACTIVE" or "PAUSED" context (string, optional): Schedule context, in a human-readable representation (omitted for private-mode applications) lastFiredAt (string, optional): When the schedule last triggered (ISO 8601) automaticBackfill (bool): Whether missed runs are automatically backfilled cronTimezone (string, optional): Timezone for the cron expression applicationName (string, optional): Name of the application that owns the schedule
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "schedule_name": {
      "title": "Schedule Name",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "schedule_name"
  ],
  "type": "object",
  "title": "get_scheduleArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "get_scheduleDictOutput"
}
——
get_workflowGet details of a specific workflow from DBOS Conductor. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow to retrieve Returns: workflowId (string): The workflow ID status (string): PENDING, SUCCESS, ERROR, CANCELLED, ENQUEUED, DELAYED, or MAX_RECOVERY_ATTEMPTS_EXCEEDED workflowName (string): The name of the workflow function workflowClass (string, optional): The name of the workflow's class, if any workflowConfig (string, optional): The name with which the workflow's class instance was configured, if any user (string, optional): The user who ran the workflow, if specified assumedRole (string, optional): The role with which the workflow ran, if specified roles (string, optional): All roles which the authenticated user could assume (JSON array) input (string, optional): The workflow input, in a human-readable representation output (string, optional): The workflow's output, if any, in a human-readable representation error (string, optional): The error the workflow threw, if any createdAt (string): Workflow start time (ISO 8601) updatedAt (string): Last time the workflow status was updated (ISO 8601) queueName (string, optional): If this workflow was enqueued, on which queue appVersion (string): The application version on which this workflow was started executorId (string, optional): The executor to most recently execute this workflow timeoutMs (int, optional): The start-to-close timeout of the workflow in ms deadline (string, optional): The deadline of the workflow, computed by adding its timeout to its start time (ISO 8601) deduplicationId (string, optional): Unique ID for deduplication on a queue priority (int): Priority of the workflow on the queue (1-2147483647, lower is higher priority) queuePartitionKey (string, optional): If this workflow is enqueued on a partitioned queue, its partition key forkedFrom (string, optional): If this workflow was forked from another, that workflow's ID parentWorkflowId (string, optional): If this is a child workflow, the ID of the parent workflow that started it dequeuedAt (string, optional): When this workflow was dequeued from its queue (ISO 8601) wasForkedFrom (bool): Whether another workflow has been forked from this one (true on the fork's source, not on the fork itself; a fork has forkedFrom set instead) delayUntil (string, optional): If this workflow has a delayed start, the time until which it is delayed (ISO 8601) completedAt (string, optional): When this workflow completed (ISO 8601) attributes (string, optional): Application-defined attributes attached to the workflow, if any scheduleName (string, optional): If this workflow was started by a schedule, that schedule's name applicationName (string, optional): Name of the application that owns the workflow
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "get_workflowArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "get_workflowDictOutput"
}
——
get_workflow_aggregatesGet workflow aggregate metrics from DBOS Conductor. Returns workflow aggregates grouped by one or more dimensions. Useful for dashboards and understanding workflow status at a glance (e.g., "how many workflows failed today?", "how many workflows are pending per queue?", "what's the worst queue-wait time per workflow name?"). Select at least one select_* flag to populate aggregate values. At least one group_by_* flag is mandatory to break the results down by dimension; a query with no group_by_* will fail. Args: application_name (string, required): Name of the DBOS application group_by_status (bool, optional): Group results by workflow status (default: false) group_by_name (bool, optional): Group results by workflow name (default: false) group_by_queue_name (bool, optional): Group results by queue name (default: false) group_by_executor_id (bool, optional): Group results by executor ID (default: false) group_by_application_version (bool, optional): Group results by application version (default: false) group_by_application_name (bool, optional): Group results by application name (default: false) select_count (bool, optional): Include count of workflows in each group (default: false) select_min_created_at (bool, optional): Include earliest creation time (ISO 8601) in each group (default: false) select_max_queue_wait_ms (bool, optional): Include max queue wait time (ms) in each group (default: false) select_max_total_latency_ms (bool, optional): Include max end-to-end latency (ms) in each group (default: false) status (array of strings, optional): Filter to these statuses before aggregating start_time (string, optional): Filter workflows created after this time (ISO 8601) end_time (string, optional): Filter workflows created before this time (ISO 8601) completed_after (string, optional): Filter workflows completed after this time (ISO 8601) completed_before (string, optional): Filter workflows completed before this time (ISO 8601) dequeued_after (string, optional): Filter workflows dequeued after this time (ISO 8601) dequeued_before (string, optional): Filter workflows dequeued before this time (ISO 8601) name (array of strings, optional): Filter to these workflow names before aggregating app_version (array of strings, optional): Filter to these application versions executor_id (array of strings, optional): Filter to these executor IDs queue_name (array of strings, optional): Filter to these queue names workflow_id_prefix (array of strings, optional): Filter to workflow IDs starting with these prefixes time_bucket_size_ms (int, optional): Bucket aggregates into time windows of this many milliseconds schedule_name (array of strings, optional): Filter to workflows started by these schedules Returns: aggregates: Array of aggregate objects, each containing: - group (object): Map of dimension names to values. Keys are snake_case: status, name, queue_name, executor_id, application_version, application_name (e.g., {"status": "ERROR", "name": "processOrder"}). If time_bucket_size_ms is set, each group also carries a time_bucket key whose value is the bucket's start time as Unix epoch milliseconds (a string), not ISO 8601. - count (int, optional): Number of workflows matching this group (if select_count) - minCreatedAt (string, optional): Earliest creation time, ISO 8601 (if select_min_created_at) - maxQueueWaitMs (int, optional): Max queue wait time in ms (if select_max_queue_wait_ms) - maxTotalLatencyMs (int, optional): Max end-to-end latency in ms (if select_max_total_latency_ms) application (string): Name of the application queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "group_by_status": {
      "default": false,
      "title": "Group By Status",
      "type": "boolean"
    },
    "group_by_name": {
      "default": false,
      "title": "Group By Name",
      "type": "boolean"
    },
    "group_by_queue_name": {
      "default": false,
      "title": "Group By Queue Name",
      "type": "boolean"
    },
    "group_by_executor_id": {
      "default": false,
      "title": "Group By Executor Id",
      "type": "boolean"
    },
    "group_by_application_version": {
      "default": false,
      "title": "Group By Application Version",
      "type": "boolean"
    },
    "group_by_application_name": {
      "default": false,
      "title": "Group By Application Name",
      "type": "boolean"
    },
    "select_count": {
      "default": false,
      "title": "Select Count",
      "type": "boolean"
    },
    "select_min_created_at": {
      "default": false,
      "title": "Select Min Created At",
      "type": "boolean"
    },
    "select_max_queue_wait_ms": {
      "default": false,
      "title": "Select Max Queue Wait Ms",
      "type": "boolean"
    },
    "select_max_total_latency_ms": {
      "default": false,
      "title": "Select Max Total Latency Ms",
      "type": "boolean"
    },
    "status": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Status"
    },
    "start_time": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Start Time"
    },
    "end_time": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "End Time"
    },
    "completed_after": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Completed After"
    },
    "completed_before": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Completed Before"
    },
    "dequeued_after": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dequeued After"
    },
    "dequeued_before": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dequeued Before"
    },
    "name": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Name"
    },
    "app_version": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "App Version"
    },
    "executor_id": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Executor Id"
    },
    "queue_name": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Name"
    },
    "workflow_id_prefix": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Workflow Id Prefix"
    },
    "time_bucket_size_ms": {
      "anyOf": [
        {
          "type": "integer"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Time Bucket Size Ms"
    },
    "schedule_name": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Schedule Name"
    }
  },
  "required": [
    "application_name"
  ],
  "type": "object",
  "title": "get_workflow_aggregatesArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "get_workflow_aggregatesDictOutput"
}
——
get_workflow_eventsGet events published by a workflow from DBOS Conductor. Events are OUTBOUND: a workflow publishes them about its own state or progress via setEvent, and anything holding the workflow ID (another workflow, an HTTP handler, a client) reads them via getEvent. A workflow that never received anything can still have events. To see messages sent TO a workflow, use get_workflow_notifications instead. Each event has a string key and a value. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow Returns: events: Array of event objects, each containing: - key (string): The event key - value (string): The event value, in a human-readable representation count (int): Number of events returned workflow_id (string): The workflow ID queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "get_workflow_eventsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "get_workflow_eventsDictOutput"
}
——
get_workflow_notificationsGet notifications received by a workflow from DBOS Conductor. Notifications are INBOUND: another party sends a message to this workflow on a topic via send, and the workflow consumes it via recv. This is the tool to use for "what did this workflow receive?" — for what a workflow published about itself, use get_workflow_events instead. Unlike events, multiple notifications can be sent on the same topic. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow Returns: notifications: Array of notification objects, each containing: - topic (string, optional): The notification topic - message (string): The notification message, in a human-readable representation - createdAt (string): When the notification was sent (ISO 8601) - consumed (bool): Whether the notification has been consumed by the workflow count (int): Number of notifications returned workflow_id (string): The workflow ID queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "get_workflow_notificationsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "get_workflow_notificationsDictOutput"
}
——
list_application_versionsList all versions of an application from DBOS Conductor. Each time an application connects with a new version string, a new version is recorded. Use set_latest_application_version to control which version is considered current. Args: application_name (string, required): Name of the DBOS application Returns: versions: Array of version objects, each containing: - versionId (string): Unique identifier for this version - versionName (string): The version string - versionTimestamp (string): Version timestamp (ISO 8601) - createdAt (string): When this version was first seen (ISO 8601) count (int): Number of versions returned application (string): Name of the application queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    }
  },
  "required": [
    "application_name"
  ],
  "type": "object",
  "title": "list_application_versionsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "list_application_versionsDictOutput"
}
——
list_applicationsList all applications registered with DBOS Conductor. Returns: applications: Array of application objects, each containing: - id (string): Unique identifier - name (string): Name of the application - orgId (string): Organization ID - status (string): "AVAILABLE" or "UNAVAILABLE" - language (string, optional): Programming language of the application - gcTimeThresholdMs (int, optional): Garbage collection time threshold in milliseconds - gcRowsThreshold (int, optional): Garbage collection rows threshold (default 1000000) - globalTimeoutMs (int, optional): Global workflow timeout in milliseconds - executorTimeoutSecs (int): Seconds a disconnected executor can remain before being marked dead and having its workflows recovered (default 60) - privateMode (bool): If true, Conductor never loads application data such as workflow inputs/outputs or schedule contexts - dbosCloud (bool): Whether the application was provisioned by DBOS Cloud count: Number of applications returned
Input schema
{
  "properties": {},
  "type": "object",
  "title": "list_applicationsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "list_applicationsDictOutput"
}
——
list_executorsList executors for an application from DBOS Conductor. Executors are running instances of your application connected to Conductor. Args: application_name (string, required): Name of the DBOS application Returns: executors: Array of executor objects, each containing: - executorId (string): Unique identifier for this executor - appId (string): The application ID - appVersion (string): Version of the application running on this executor - status (string): HEALTHY, DISCONNECTED, or DEAD - hostId (string, optional): Host identifier of the executor - hostname (string, optional): Hostname of the executor - createdAt (string): When this executor first registered with Conductor (ISO 8601) - updatedAt (string): When this executor's status last changed (ISO 8601). - language (string, optional): Programming language (e.g., "python", "typescript") - dbosVersion (string, optional): Version of the DBOS library - executorMetadata (object, optional): Arbitrary metadata reported by the executor count (int): Number of executors returned application (string): Name of the application queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    }
  },
  "required": [
    "application_name"
  ],
  "type": "object",
  "title": "list_executorsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "list_executorsDictOutput"
}
——
list_schedulesList schedules for an application from DBOS Conductor. Schedules automatically trigger workflows on a cron-based schedule. Args: application_name (string, required): Name of the DBOS application status (string, optional): Filter by schedule status (e.g., "ACTIVE", "PAUSED") workflow_name (string, optional): Filter by the workflow function the schedule triggers schedule_name_prefix (string, optional): Filter by schedule name prefix Returns: schedules: Array of schedule objects, each containing: - scheduleId (string): Unique identifier - scheduleName (string): Name of the schedule - workflowName (string): The workflow function this schedule triggers - workflowClass (string, optional): The workflow's class name, if any - cronExpression (string): Cron expression defining the schedule - status (string): "ACTIVE" or "PAUSED" - context (string, optional): Schedule context, in a human-readable representation (omitted for private-mode applications) - lastFiredAt (string, optional): When the schedule last triggered (ISO 8601) - automaticBackfill (bool): Whether missed runs are automatically backfilled - cronTimezone (string, optional): Timezone for the cron expression - applicationName (string, optional): Name of the application that owns the schedule count (int): Number of schedules returned application (string): Name of the application queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "status": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Status"
    },
    "workflow_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Workflow Name"
    },
    "schedule_name_prefix": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Schedule Name Prefix"
    }
  },
  "required": [
    "application_name"
  ],
  "type": "object",
  "title": "list_schedulesArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "list_schedulesDictOutput"
}
——
list_stepsGet execution steps for a workflow from DBOS Conductor. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow limit (int, optional): Maximum number of steps to return offset (int, optional): Number of steps to skip (for pagination) Returns: steps: Array of step objects, each containing: - stepId (int): The unique ID of the step in the workflow - stepName (string): The name of the step - output (string, optional): The step's output, if any - error (string, optional): The error the step threw, if any - childWorkflowId (string, optional): If the step starts or retrieves the result of a workflow, its ID - startedAt (string, optional): When this step started (ISO 8601) - completedAt (string, optional): When this step completed (ISO 8601) count (int): Number of steps returned workflow_id (string): The workflow ID queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    },
    "limit": {
      "anyOf": [
        {
          "type": "integer"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Limit"
    },
    "offset": {
      "anyOf": [
        {
          "type": "integer"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Offset"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "list_stepsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "list_stepsDictOutput"
}
——
list_workflowsList workflows from DBOS Conductor with optional filters. Args: application_name (string, required): Name of the DBOS application workflow_uuids (array of strings, optional): Filter to only these specific workflow IDs workflow_name (string or array of strings, optional): Filter by workflow function name authenticated_user (string or array of strings, optional): Filter by the user who started the workflow start_time (string, optional): Filter workflows created after this time (ISO 8601) end_time (string, optional): Filter workflows created before this time (ISO 8601) completed_after (string, optional): Filter workflows completed after this time (ISO 8601) completed_before (string, optional): Filter workflows completed before this time (ISO 8601) dequeued_after (string, optional): Filter workflows dequeued after this time (ISO 8601) dequeued_before (string, optional): Filter workflows dequeued before this time (ISO 8601) status (string or array of strings, optional): Filter by status - PENDING, SUCCESS, ERROR, CANCELLED, ENQUEUED, DELAYED, or MAX_RECOVERY_ATTEMPTS_EXCEEDED application_version (string or array of strings, optional): Filter by application version forked_from (string or array of strings, optional): Filter to workflows forked from this workflow ID parent_workflow_id (string or array of strings, optional): Filter to child workflows of this parent workflow ID queue_name (string or array of strings, optional): Filter by workflow queue name limit (int, optional): Maximum number of workflows to return offset (int, optional): Number of workflows to skip (for pagination) sort_desc (bool, optional): Sort by creation time descending (default: false, ascending) workflow_id_prefix (string or array of strings, optional): Filter to workflow IDs starting with this prefix load_input (bool, optional): Include workflow input data in response (default: false; always false for private-mode applications) load_output (bool, optional): Include workflow output data in response (default: false; always false for private-mode applications) executor_id (string or array of strings, optional): Filter by executor ID running the workflow queues_only (bool, optional): Only return workflows that are on a queue (default: false) was_forked_from (bool, optional): If true, only return workflows that other workflows have been forked from (fork sources). If false, only return workflows that have never been forked from. To find the forks themselves, use forked_from instead. has_parent (bool, optional): If true, only return child workflows. If false, only return workflows without a parent. schedule_name (string or array of strings, optional): Filter to workflows started by these schedules Returns: workflows: Array of workflow objects, each containing: - workflowId (string): The workflow ID - status (string): PENDING, SUCCESS, ERROR, CANCELLED, ENQUEUED, DELAYED, or MAX_RECOVERY_ATTEMPTS_EXCEEDED - workflowName (string): The name of the workflow function - workflowClass (string, optional): The name of the workflow's class, if any - workflowConfig (string, optional): The name with which the workflow's class instance was configured, if any - user (string, optional): The user who ran the workflow, if specified - assumedRole (string, optional): The role with which the workflow ran, if specified - roles (string, optional): All roles which the authenticated user could assume (JSON array) - input (string, optional): The workflow input, in a human-readable representation (only if load_input=true) - output (string, optional): The workflow's output, if any, in a human-readable representation (only if load_output=true) - error (string, optional): The error the workflow threw, if any (only if load_output=true; get_workflow always returns it) - createdAt (string): Workflow start time (ISO 8601) - updatedAt (string): Last time the workflow status was updated (ISO 8601) - queueName (string, optional): If this workflow was enqueued, on which queue - appVersion (string): The application version on which this workflow was started - executorId (string, optional): The executor to most recently execute this workflow - timeoutMs (int, optional): The start-to-close timeout of the workflow in ms - deadline (string, optional): The deadline of the workflow, computed by adding its timeout to its start time (ISO 8601) - deduplicationId (string, optional): Unique ID for deduplication on a queue - priority (int): Priority of the workflow on the queue (1-2147483647, lower is higher priority) - queuePartitionKey (string, optional): If this workflow is enqueued on a partitioned queue, its partition key - forkedFrom (string, optional): If this workflow was forked from another, that workflow's ID - parentWorkflowId (string, optional): If this is a child workflow, the ID of the parent workflow that started it - dequeuedAt (string, optional): When this workflow was dequeued from its queue (ISO 8601) - wasForkedFrom (bool): Whether another workflow has been forked from this one (true on the fork's source, not on the fork itself; a fork has forkedFrom set instead) - delayUntil (string, optional): If this workflow has a delayed start, the time until which it is delayed (ISO 8601) - completedAt (string, optional): When this workflow completed (ISO 8601) - attributes (string, optional): Application-defined attributes attached to the workflow, if any - scheduleName (string, optional): If this workflow was started by a schedule, that schedule's name - applicationName (string, optional): Name of the application that owns the workflow count (int): Number of workflows returned application (string): Name of the application queried
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_uuids": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Workflow Uuids"
    },
    "workflow_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Workflow Name"
    },
    "authenticated_user": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Authenticated User"
    },
    "start_time": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Start Time"
    },
    "end_time": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "End Time"
    },
    "completed_after": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Completed After"
    },
    "completed_before": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Completed Before"
    },
    "dequeued_after": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dequeued After"
    },
    "dequeued_before": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dequeued Before"
    },
    "status": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Status"
    },
    "application_version": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Application Version"
    },
    "forked_from": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Forked From"
    },
    "parent_workflow_id": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Parent Workflow Id"
    },
    "queue_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Name"
    },
    "limit": {
      "anyOf": [
        {
          "type": "integer"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Limit"
    },
    "offset": {
      "anyOf": [
        {
          "type": "integer"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Offset"
    },
    "sort_desc": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Sort Desc"
    },
    "workflow_id_prefix": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Workflow Id Prefix"
    },
    "load_input": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Load Input"
    },
    "load_output": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Load Output"
    },
    "executor_id": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Executor Id"
    },
    "queues_only": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queues Only"
    },
    "was_forked_from": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Was Forked From"
    },
    "has_parent": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Has Parent"
    },
    "schedule_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Schedule Name"
    }
  },
  "required": [
    "application_name"
  ],
  "type": "object",
  "title": "list_workflowsArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "list_workflowsDictOutput"
}
——
loginStart DBOS Cloud login flow. Returns a URL that the user must open in their browser to authenticate. After authenticating, call login_complete to finish the login process. Returns: Dictionary with url to visit and instructions.
Input schema
{
  "properties": {},
  "type": "object",
  "title": "loginArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "loginDictOutput"
}
——
login_completeComplete DBOS Cloud login after authenticating in browser. Call this after you have opened the login URL and authenticated. Returns: Dictionary with userName and organization on success.
Input schema
{
  "properties": {},
  "type": "object",
  "title": "login_completeArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "login_completeDictOutput"
}
——
pause_schedulePause a schedule, stopping it from triggering new workflows. The schedule can be resumed later with resume_schedule. Args: application_name (string, required): Name of the DBOS application schedule_name (string, required): Name of the schedule to pause Returns: message (string): Confirmation message schedule_name (string): The paused schedule name
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "schedule_name": {
      "title": "Schedule Name",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "schedule_name"
  ],
  "type": "object",
  "title": "pause_scheduleArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "pause_scheduleDictOutput"
}
——
resume_scheduleResume a paused schedule, allowing it to trigger workflows again. Args: application_name (string, required): Name of the DBOS application schedule_name (string, required): Name of the schedule to resume Returns: message (string): Confirmation message schedule_name (string): The resumed schedule name
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "schedule_name": {
      "title": "Schedule Name",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "schedule_name"
  ],
  "type": "object",
  "title": "resume_scheduleArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "resume_scheduleDictOutput"
}
——
resume_workflowResume a workflow. Resumes execution of a workflow that is in CANCELLED state. You can also use this on a workflow in the ENQUEUED state to immediately start it, bypassing its queue. You cannot resume a workflow in any other state. Args: application_name (string, required): Name of the DBOS application workflow_id (string, required): ID of the workflow to resume queue_name (string, optional): If provided, enqueue the resumed workflow onto this queue instead of running it immediately Returns: message (string): Confirmation message workflow_id (string): The resumed workflow ID
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "workflow_id": {
      "title": "Workflow Id",
      "type": "string"
    },
    "queue_name": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Queue Name"
    }
  },
  "required": [
    "application_name",
    "workflow_id"
  ],
  "type": "object",
  "title": "resume_workflowArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "resume_workflowDictOutput"
}
——
set_latest_application_versionSet the latest version for an application in DBOS Conductor. This controls which version is considered current. Useful for rolling back to a previous version or promoting a specific version. Args: application_name (string, required): Name of the DBOS application version_name (string, required): The version string to set as latest Returns: message (string): Confirmation message version_name (string): The version that was set as latest
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "version_name": {
      "title": "Version Name",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "version_name"
  ],
  "type": "object",
  "title": "set_latest_application_versionArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "set_latest_application_versionDictOutput"
}
——
trigger_scheduleManually trigger a schedule to run its workflow immediately. This does not affect the schedule's regular cron timing. Args: application_name (string, required): Name of the DBOS application schedule_name (string, required): Name of the schedule to trigger Returns: workflow_id (string, optional): The ID of the triggered workflow, if one was created schedule_name (string): The triggered schedule name
Input schema
{
  "properties": {
    "application_name": {
      "title": "Application Name",
      "type": "string"
    },
    "schedule_name": {
      "title": "Schedule Name",
      "type": "string"
    }
  },
  "required": [
    "application_name",
    "schedule_name"
  ],
  "type": "object",
  "title": "trigger_scheduleArguments"
}
Output schema
{
  "type": "object",
  "additionalProperties": true,
  "title": "trigger_scheduleDictOutput"
}
——

Resources 0

  • None observed.

Resource templates 0

  • None observed.

Prompts 0

  • None observed.

Remote endpoints

EndpointTransportAuthenticationHealthObserved
No verified remote endpoint is linked.

DBOS MCP Server questions

How do I install DBOS MCP Server?

Install the selected package version with: python -m pip install 'dbos-mcp==0.8.0'

What tools does DBOS MCP Server provide?

DBOS MCP Server exposed 25 tools during independent protocol observation, including bulk_cancel_workflows, bulk_delete_workflows, bulk_resume_workflows, cancel_workflow, delete_workflow, fork_from_failure, fork_workflow, get_schedule, and others.

Is DBOS MCP Server secure?

Our scanner tested version 0.8.0 without proving a finding in the methods exercised. This is not a guarantee that every deployment is secure.

Explore related MCP server guides

Curated product and capability guides containing this catalog record.

Official vs Community MCP Servers

Let’s talk about MCP security.

Share your details and our security team will contact you.