prefect.server.api.flow_run_states

Routes for interacting with flow run state objects.

read_flow_run_state(flow_run_state_id=Path(..., description='The flow run state id', alias='id'), db=Depends(provide_database_interface)) async

Get a flow run state by id.

Source code in src/prefect/server/api/flow_run_states.py

@router.get("/{id}")
async def read_flow_run_state(
    flow_run_state_id: UUID = Path(
        ..., description="The flow run state id", alias="id"
    ),
    db: PrefectDBInterface = Depends(provide_database_interface),
) -> schemas.states.State:
    """
    Get a flow run state by id.
    """
    async with db.session_context() as session:
        flow_run_state = await models.flow_run_states.read_flow_run_state(
            session=session, flow_run_state_id=flow_run_state_id
        )
    if not flow_run_state:
        raise HTTPException(
            status.HTTP_404_NOT_FOUND, detail="Flow run state not found"
        )
    return flow_run_state

read_flow_run_states(flow_run_id, db=Depends(provide_database_interface)) async

Get states associated with a flow run.

Source code in src/prefect/server/api/flow_run_states.py

@router.get("/")
async def read_flow_run_states(
    flow_run_id: UUID,
    db: PrefectDBInterface = Depends(provide_database_interface),
) -> List[schemas.states.State]:
    """
    Get states associated with a flow run.
    """
    async with db.session_context() as session:
        return await models.flow_run_states.read_flow_run_states(
            session=session, flow_run_id=flow_run_id
        )