Skip to content
Console
Menu

Queues

Workflows

Getting Started

Authentication

KV Store

Read shards on a distributed run

Reads a page of the run's shards, in queue order.

This method is not served on the public API. api.sylphx.com does not route this call: its backend is not deployed behind the public API, or does not implement the call. This page documents the contract. It is kept out of the sidebar and of search engines.

Reads a page of the run's shards, in queue order.

  • Path GET https://api.sylphx.com/v1/orgs/acme/projects/shop/envs/production/distributed_jobs/distributed-job/distributed_runs/distributed-run:readShards
  • Scope workflows:read
  • Effect read — nothing is written.
  • Collection distributed_runs
  • Query page_size, page_token, state_filter

#Request

FieldTypeWhat it is
namestringThe name of the distributed run. Required.
page_sizeint32At most this many; default 100, clamped to 1000.
page_tokenstringnext_page_token of the previous page.
state_filterShardStateOnly shards in this state; unset reads every shard. One of pending, leased, succeeded, failed.

#Response

FieldTypeWhat it is
shardsShard[]The page, in queue order.
next_page_tokenstringThe token of the next page; empty on the last page.

#Shard

FieldTypeWhat it is
idstringThe shard id, unique in its run. Output only.
seqint64Order in the run's queue, from 0. Output only.
stateShardStateThe shard's state. Output only. One of pending, leased, succeeded, failed.
attemptsint32Attempts counted so far (failures and timeouts, not preemptions). Output only.
workerstringThe worker holding or last holding the lease. Output only.
outputsvalueWhat the worker reported at complete, any JSON. Output only.
errorstringThe last failure's message. Output only.

#Errors

Every error arrives in the body Errors describes.

#Examples

curl "https://api.sylphx.com/v1/orgs/acme/projects/shop/envs/production/distributed_jobs/distributed-job/distributed_runs/distributed-run:readShards" \
  -H "Authorization: Bearer $SYLPHX_API_KEY"