queue-management

Queue and batch management: create, configure, and monitor queues for concurrent automation execution, add batch items from CSV, and track batch progress

Server path: /queue-management | Type: Embedded | PCID required: No

Tools

Tool	Description
queue-management_create_queue	Create a new queue for managing concurrent execution of automation runs. Configure concurrency limits, retry policies, and priority.
queue-management_list_queues	List all queues in the current organization. Returns queue details including status, concurrency limits, and priority.
queue-management_get_queue	Get details for a specific queue by ID, including its configuration, status, and access control.
queue-management_update_queue	Update queue configuration (name, description, concurrency limit, max retries, priority). Requires the current version number for optimistic locking.
queue-management_delete_queue	Delete a queue and all its items. This action is destructive and cannot be undone.
queue-management_start_queue	Start processing a paused queue. The queue will begin executing pending runs up to its concurrency limit.
queue-management_pause_queue	Pause a running queue. In-progress runs will complete, but no new runs will start.
queue-management_get_queue_stats	Get statistics for a queue including pending and running item counts. Optionally filter by date range.
queue-management_get_queue_runs	List runs for a specific queue. Returns run details including status, timestamps, and results.
queue-management_create_batch	Create a new batch in a queue from a CSV file. Each row becomes a run, executed via the specified trigger. Optionally configure a completion action (trigger or webhook) when the batch finishes.
queue-management_get_batch_status	Get the status of a batch including run counts (requested, complete, failed, timed out) and overall status (pending, running, complete, canceled).

---

queue-management_create_queue

Create a new queue for managing concurrent execution of automation runs. Configure concurrency limits, retry policies, and priority.

Parameters:

Parameter	Type	Required	Default	Description
name	string	Yes	—	Name for the queue
description	string	No	—	Description of the queue purpose
concurrencyLimit	number	Yes	—	Maximum number of concurrent runs (must be >= 1)
maxRetries	number	No	0	Maximum retry attempts for failed runs (0-3)
priority	number	No	5	Queue priority (1=highest, 10=lowest, default=5)

Show inputSchema

{
  "type": "object",
  "properties": {
    "name": {
      "type": "string",
      "description": "Name for the queue"
    },
    "description": {
      "type": "string",
      "description": "Description of the queue purpose"
    },
    "concurrencyLimit": {
      "type": "number",
      "description": "Maximum number of concurrent runs (must be >= 1)"
    },
    "maxRetries": {
      "type": "number",
      "default": 0,
      "description": "Maximum retry attempts for failed runs (0-3)"
    },
    "priority": {
      "type": "number",
      "default": 5,
      "description": "Queue priority (1=highest, 10=lowest, default=5)"
    }
  },
  "required": [
    "name",
    "concurrencyLimit"
  ]
}

---

queue-management_list_queues

List all queues in the current organization. Returns queue details including status, concurrency limits, and priority.

Parameters: None

Show inputSchema

{
  "type": "object",
  "properties": {}
}

---

queue-management_get_queue

Get details for a specific queue by ID, including its configuration, status, and access control.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue to retrieve

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue to retrieve"
    }
  },
  "required": [
    "queueId"
  ]
}

---

queue-management_update_queue

Update queue configuration (name, description, concurrency limit, max retries, priority). Requires the current version number for optimistic locking.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue to update
name	string	No	—	Updated queue name
description	string	No	—	Updated queue description
concurrencyLimit	number	No	—	Updated maximum concurrent runs
maxRetries	number	No	—	Updated maximum retry attempts (0-3)
priority	number	No	—	Updated priority (1=highest, 10=lowest)
version	number	Yes	—	Current version number for optimistic locking (get from queue-management_get_queue)

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue to update"
    },
    "name": {
      "type": "string",
      "description": "Updated queue name"
    },
    "description": {
      "type": "string",
      "description": "Updated queue description"
    },
    "concurrencyLimit": {
      "type": "number",
      "description": "Updated maximum concurrent runs"
    },
    "maxRetries": {
      "type": "number",
      "description": "Updated maximum retry attempts (0-3)"
    },
    "priority": {
      "type": "number",
      "description": "Updated priority (1=highest, 10=lowest)"
    },
    "version": {
      "type": "number",
      "description": "Current version number for optimistic locking (get from queue-management_get_queue)"
    }
  },
  "required": [
    "queueId",
    "version"
  ]
}

---

queue-management_delete_queue

Delete a queue and all its items. This action is destructive and cannot be undone.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue to delete

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue to delete"
    }
  },
  "required": [
    "queueId"
  ]
}

---

queue-management_start_queue

Start processing a paused queue. The queue will begin executing pending runs up to its concurrency limit.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue to start

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue to start"
    }
  },
  "required": [
    "queueId"
  ]
}

---

queue-management_pause_queue

Pause a running queue. In-progress runs will complete, but no new runs will start.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue to pause

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue to pause"
    }
  },
  "required": [
    "queueId"
  ]
}

---

queue-management_get_queue_stats

Get statistics for a queue including pending and running item counts. Optionally filter by date range.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue
startDate	string	No	—	Filter stats from this date (ISO 8601 format, e.g. 2024-01-01T00:00:00Z)
endDate	string	No	—	Filter stats until this date (ISO 8601 format)

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue"
    },
    "startDate": {
      "type": "string",
      "description": "Filter stats from this date (ISO 8601 format, e.g. 2024-01-01T00:00:00Z)"
    },
    "endDate": {
      "type": "string",
      "description": "Filter stats until this date (ISO 8601 format)"
    }
  },
  "required": [
    "queueId"
  ]
}

---

queue-management_get_queue_runs

List runs for a specific queue. Returns run details including status, timestamps, and results.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue
limit	number	No	50	Maximum number of runs to return (default: 50)
status	string	No	—	Filter runs by status (e.g. RUNNING, COMPLETE, FAILED, ERROR)

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue"
    },
    "limit": {
      "type": "number",
      "default": 50,
      "description": "Maximum number of runs to return (default: 50)"
    },
    "status": {
      "type": "string",
      "description": "Filter runs by status (e.g. RUNNING, COMPLETE, FAILED, ERROR)"
    }
  },
  "required": [
    "queueId"
  ]
}

---

queue-management_create_batch

Create a new batch in a queue from a CSV file. Each row becomes a run, executed via the specified trigger. Optionally configure a completion action (trigger or webhook) when the batch finishes.

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue to add items to
triggerId	string	Yes	—	ID of the trigger to execute for each queue item
csvUrl	string	No	—	URL to a CSV file (provide either csvUrl or csvData)
csvData	string	No	—	Inline CSV data as a string (provide either csvUrl or csvData)
batchSize	number	No	—	Number of rows per batch (0 or 1 = individual rows, >1 = batch mode)
onDoneTriggerId	string	No	—	Trigger ID to execute when the batch completes
onDoneWebhookUrl	string	No	—	Webhook URL to call when the batch completes

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue to add items to"
    },
    "triggerId": {
      "type": "string",
      "description": "ID of the trigger to execute for each queue item"
    },
    "csvUrl": {
      "type": "string",
      "description": "URL to a CSV file (provide either csvUrl or csvData)"
    },
    "csvData": {
      "type": "string",
      "description": "Inline CSV data as a string (provide either csvUrl or csvData)"
    },
    "batchSize": {
      "type": "number",
      "description": "Number of rows per batch (0 or 1 = individual rows, >1 = batch mode)"
    },
    "onDoneTriggerId": {
      "type": "string",
      "description": "Trigger ID to execute when the batch completes"
    },
    "onDoneWebhookUrl": {
      "type": "string",
      "description": "Webhook URL to call when the batch completes"
    }
  },
  "required": [
    "queueId",
    "triggerId"
  ]
}

---

queue-management_get_batch_status

Get the status of a batch including run counts (requested, complete, failed, timed out) and overall status (pending, running, complete, canceled).

Parameters:

Parameter	Type	Required	Default	Description
queueId	string	Yes	—	ID of the queue
batchId	string	Yes	—	ID of the batch to check

Show inputSchema

{
  "type": "object",
  "properties": {
    "queueId": {
      "type": "string",
      "description": "ID of the queue"
    },
    "batchId": {
      "type": "string",
      "description": "ID of the batch to check"
    }
  },
  "required": [
    "queueId",
    "batchId"
  ]
}