​
prefect.server.models.task_run_states

Functions for interacting with task run state ORM objects. Intended for internal use by the Prefect REST API.

​
Functions

​
read_task_run_state 

read_task_run_state(db: PrefectDBInterface, session: AsyncSession, task_run_state_id: UUID) -> Union[orm_models.TaskRunState, None]
Reads a task run state by id. Args:
  • session: A database session
  • task_run_state_id: a task run state id
Returns:
  • orm_models.TaskRunState: the task state

​
read_task_run_states 

read_task_run_states(db: PrefectDBInterface, session: AsyncSession, task_run_id: UUID) -> Sequence[orm_models.TaskRunState]
Reads task runs states for a task run. Args:
  • session: A database session
  • task_run_id: the task run id
Returns:
  • List[orm_models.TaskRunState]: the task run states

​
delete_task_run_state 

delete_task_run_state(db: PrefectDBInterface, session: AsyncSession, task_run_state_id: UUID) -> bool
Delete a task run state by id. Args:
  • session: A database session
  • task_run_state_id: a task run state id
Returns:
  • whether or not the task run state was deleted