server.web.routes.v3.fsm.task

Routes for Tasks.

Attributes

logger

Functions

bind_tasks_no_args() → Any)

Bind the task objects to the database.

bind_task_args(, dialect)

Add task args and associated task ids to the database.

bind_task_attributes(, dialect)

Add task attributes and associated attribute types to the database.

bind_task_resources() → Any)

Add the task resources for a given task.

get_most_recent_ti_error() → Any)

Route to determine the cause of the most recent task_instance's error.

set_task_resume_state() → Any)

An endpoint to set all tasks to a resumable state for a workflow.

Module Contents

server.web.routes.v3.fsm.task.logger
async server.web.routes.v3.fsm.task.bind_tasks_no_args(request: fastapi.Request, db: sqlalchemy.orm.Session = Depends(get_db)) → Any

Bind the task objects to the database.

async server.web.routes.v3.fsm.task.bind_task_args(request: fastapi.Request, db: sqlalchemy.orm.Session = Depends(get_db), dialect: str = Depends(get_dialect)) → Any

Add task args and associated task ids to the database.

async server.web.routes.v3.fsm.task.bind_task_attributes(request: fastapi.Request, db: sqlalchemy.orm.Session = Depends(get_db), dialect: str = Depends(get_dialect)) → Any

Add task attributes and associated attribute types to the database.

async server.web.routes.v3.fsm.task.bind_task_resources(request: fastapi.Request, db: sqlalchemy.orm.Session = Depends(get_db)) → Any

Add the task resources for a given task.

server.web.routes.v3.fsm.task.get_most_recent_ti_error(task_id: int, db: sqlalchemy.orm.Session = Depends(get_db)) → Any

Route to determine the cause of the most recent task_instance’s error.

Parameters:

  • task_id (int) – the ID of the task.

  • db – The database session.

Returns:

error message

async server.web.routes.v3.fsm.task.set_task_resume_state(workflow_id: int, request: fastapi.Request, db: sqlalchemy.orm.Session = Depends(get_db)) → Any

An endpoint to set all tasks to a resumable state for a workflow.

Conditioned on the workflow already being in an appropriate resume state.