qlauncher.workflow.workflow_manager

qlauncher.workflow.workflow_manager#

Summary#

Classes:

SubTask

Task

Workflow

WorkflowManager

Reference#

class qlauncher.workflow.workflow_manager.Task(func: Callable, args: tuple[Any] | None = None, kwargs: dict[str, Any] | None = None, num_output: int = 1)[source]#

Bases: object

run() → None[source]#
is_ready()[source]#
class qlauncher.workflow.workflow_manager.SubTask(task: Task, index: int)[source]#

Bases: Task

property result#
property done#
class qlauncher.workflow.workflow_manager.Workflow(tasks: list[Task], input_task: Task, output_task: Task, input_format: type[Problem | Model])[source]#

Bases: Algorithm

run(problem: Algorithm, backend: Backend) → Any[source]#

Runs the algorithm on a specific problem using a backend.

Parameters:

  • problem (Problem) – The problem to be solved.

  • backend (Backend) – The backend to be used for execution.

get_input_format() → type[Model][source]#
class qlauncher.workflow.workflow_manager.WorkflowManager(manager: Literal['ql', 'prefect', 'airflow'] = 'ql')[source]#

Bases: object

task(func, args: tuple | None = None, kwargs: dict | None = None, num_output=None) → Task[source]#
print_dag() → None[source]#
input(format: type[Problem | Model])[source]#
output(task: Task) → None[source]#
to_workflow() → Workflow[source]#