Get Scheduled Flow Runs

Load scheduled runs for a worker

Headers

x-prefect-api-version

string

Path Parameters

name

string

required

The work pool name

Body

application/json

limit

integer

Defaults to PREFECT_API_DEFAULT_LIMIT if not provided.

scheduled_after

string

The minimum time to look for scheduled flow runs

scheduled_before

string

The maximum time to look for scheduled flow runs

work_queue_names

string[]

The names of work pool queues

Response

200 - application/json

flow_run

object

required

An ORM representation of flow run data.

Show child attributes

flow_run.created

string | null

required

flow_run.flow_id

string

required

The id of the flow being run.

flow_run.id

string

required

flow_run.updated

string | null

required

flow_run.auto_scheduled

boolean

default:

false

Whether or not the flow run was automatically scheduled.

flow_run.context

object

Additional context for the flow run.

flow_run.created_by

object | null

Optional information about the creator of this flow run.

Show child attributes

flow_run.created_by.display_value

string | null

The display value for the creator.

flow_run.created_by.id

string | null

The id of the creator of the object.

flow_run.created_by.type

string | null

The type of the creator of the object.

flow_run.deployment_id

string | null

The id of the deployment associated with this flow run, if available.

flow_run.deployment_version

string | null

The version of the deployment associated with this flow run.

flow_run.empirical_policy

object

Defines of how a flow run should retry.

Show child attributes

flow_run.empirical_policy.max_retries

integer

default:

0

deprecated

The maximum number of retries. Field is not used. Please use retries instead.

flow_run.empirical_policy.pause_keys

string[] | null

Tracks pauses this run has observed.

flow_run.empirical_policy.resuming

boolean | null

default:

false

Indicates if this run is resuming from a pause.

flow_run.empirical_policy.retries

integer | null

The number of retries.

flow_run.empirical_policy.retry_delay

integer | null

The delay time between retries, in seconds.

flow_run.empirical_policy.retry_delay_seconds

number

default:

0

deprecated

The delay between retries. Field is not used. Please use retry_delay instead.

flow_run.empirical_policy.retry_type

enum<string> | null

The type of retry this run is undergoing.

Available options:

in_process,

reschedule

flow_run.end_time

string | null

The actual end time.

flow_run.estimated_run_time

number

default:

0

A real-time estimate of the total run time.

flow_run.estimated_start_time_delta

number

default:

0

The difference between actual and expected start time.

flow_run.expected_start_time

string | null

The flow run's expected start time.

flow_run.flow_version

string | null

The version of the flow executed in this flow run.

flow_run.idempotency_key

string | null

An optional idempotency key for the flow run. Used to ensure the same flow run is not created multiple times.

flow_run.infrastructure_document_id

string | null

The block document defining infrastructure to use this flow run.

flow_run.infrastructure_pid

string | null

The id of the flow run as returned by an infrastructure block.

flow_run.job_variables

object | null

Variables used as overrides in the base job template

flow_run.labels

object | null

A dictionary of key-value labels. Values can be strings, numbers, or booleans.

Show child attributes

flow_run.labels.{key}

flow_run.name

string

The name of the flow run. Defaults to a random slug if not specified.

flow_run.next_scheduled_start_time

string | null

The next time the flow run is scheduled to start.

flow_run.parameters

object

Parameters for the flow run.

flow_run.parent_task_run_id

string | null

If the flow run is a subflow, the id of the 'dummy' task in the parent flow used to track subflow state.

flow_run.run_count

integer

default:

0

The number of times the flow run was executed.

flow_run.start_time

string | null

The actual start time.

flow_run.state

object | null

The current state of the flow run.

Show child attributes

flow_run.state.id

string

required

flow_run.state.type

enum<string>

required

Enumeration of state types.

Available options:

SCHEDULED,

PENDING,

RUNNING,

COMPLETED,

FAILED,

CANCELLED,

CRASHED,

PAUSED,

CANCELLING

flow_run.state.data

any | null

Data associated with the state, e.g. a result. Content must be storable as JSON.

flow_run.state.message

string | null

flow_run.state.name

string | null

flow_run.state.state_details

object

Show child attributes

flow_run.state.state_details.cache_expiration

string | null

flow_run.state.state_details.cache_key

string | null

flow_run.state.state_details.child_flow_run_id

string | null

flow_run.state.state_details.deferred

boolean | null

default:

false

flow_run.state.state_details.flow_run_id

string | null

flow_run.state.state_details.pause_key

string | null

flow_run.state.state_details.pause_reschedule

boolean

default:

false

flow_run.state.state_details.pause_timeout

string | null

flow_run.state.state_details.refresh_cache

boolean | null

flow_run.state.state_details.retriable

boolean | null

flow_run.state.state_details.run_input_keyset

object | null

Show child attributes

flow_run.state.state_details.run_input_keyset.{key}

string

flow_run.state.state_details.scheduled_time

string | null

flow_run.state.state_details.task_parameters_id

string | null

flow_run.state.state_details.task_run_id

string | null

flow_run.state.state_details.traceparent

string | null

flow_run.state.state_details.transition_id

string | null

flow_run.state.state_details.untrackable_result

boolean

default:

false

flow_run.state.timestamp

string

flow_run.state_id

string | null

The id of the flow run's current state.

flow_run.state_name

string | null

The name of the current flow run state.

flow_run.state_type

enum<string> | null

The type of the current flow run state.

Available options:

SCHEDULED,

PENDING,

RUNNING,

COMPLETED,

FAILED,

CANCELLED,

CRASHED,

PAUSED,

CANCELLING

flow_run.tags

string[]

A list of tags on the flow run

flow_run.total_run_time

number

default:

0

Total run time. If the flow run was executed multiple times, the time of each run will be summed.

flow_run.work_queue_id

string | null

The id of the run's work pool queue.

flow_run.work_queue_name

string | null

The work queue that handled this flow run.

work_pool_id

string

required

work_queue_id

string

required