Skip to main content
← Back to list
01Issue
FeatureShippedSwamp Club
Assigneesstack72

Relationships

#953 Docs: add swamp worker queue to worker-commands reference

Opened by stack72 · 7/4/2026· Shipped 7/4/2026

Summary

PR2 of worker-fleets phase 1 (#949) added the swamp worker queue CLI command. The docs PR (#948) shipped before this command existed, so the worker-commands reference page is missing it.

Change needed

File: content/manual/reference/remote-execution/worker-commands.md

Add a swamp worker queue section between the existing swamp worker list and swamp serve sections. Also update the page description frontmatter to include the new command.

Content to add

## `swamp worker queue`

List steps currently queued for dispatch, waiting for a matching worker.

swamp worker queue [--server ] [--repo-dir ]


When steps are waiting:

$ swamp worker queue

REQUIREMENT STEP MODEL QUEUED AT AGE labels gpu=true train-model ml/trainer 2026-07-04T10:32:15.000Z 3m target build-node compile builder/go 2026-07-04T10:34:02.000Z 1m


When the queue is empty:

$ swamp worker queue No steps are currently queued.


### JSON output

$ swamp worker queue --json


```json
[
  {
    "queueId": "a1b2c3d4-...",
    "requirement": "labels gpu=true",
    "stepName": "train-model",
    "modelType": "ml/trainer",
    "methodName": "run",
    "workflowName": "training-pipeline",
    "queuedAt": "2026-07-04T10:32:15.000Z",
    "ageMs": 180000
  }
]

JSON fields

Field Type Description
queueId string Unique identifier for this queue episode
requirement string Human-readable placement requirement
stepName string Workflow step name (if available)
modelType string Model type being dispatched
methodName string Method being invoked
workflowName string Workflow containing the step (if available)
queuedAt string ISO 8601 timestamp when the step entered the queue
ageMs number Milliseconds since the step was queued

Steps appear here when they are waiting for a matching worker and disappear once dispatched, timed out, or cancelled. Use this to diagnose why a workflow is stalled and to inform autoscaling decisions.

The same data is queryable via swamp data query:

swamp data query 'modelType == "swamp/pending-dispatch" && attributes.state == "waiting"'

## Context

This should ship alongside or shortly after PR2 (#949) merges. The command already works — this is just the reference documentation catching up.
02Bog Flow
OPENTRIAGEDIN PROGRESSSHIPPED+ 1 MOREASSIGNED+ 2 MOREREVIEW+ 4 MOREPR_MERGED+ 1 MORENOTIFICATION_SKIPPED

Shipped

7/4/2026, 1:32:34 AM

Click a lifecycle step above to view its details.

03Sludge Pulse
stack72 assigned stack727/4/2026, 12:57:07 AM

Sign in to post a ripple.