aria.orchestrator.workflows

Workflows package.

aria.orchestrator.workflows.exceptions

Workflow exceptions.

exception aria.orchestrator.workflows.exceptions.AriaEngineError

Bases: aria.exceptions.AriaError

Raised by the workflow engine.

exception aria.orchestrator.workflows.exceptions.ExecutorException

Bases: aria.exceptions.AriaError

General executor exception.

exception aria.orchestrator.workflows.exceptions.OperationNotFoundException

Bases: aria.orchestrator.workflows.exceptions.TaskCreationException

Could not find an operation on the node or relationship.

exception aria.orchestrator.workflows.exceptions.PluginNotFoundException

Bases: aria.orchestrator.workflows.exceptions.TaskCreationException

Could not find a plugin matching the plugin specification.

exception aria.orchestrator.workflows.exceptions.ProcessException(command, stderr=None, stdout=None, return_code=None)

Bases: aria.orchestrator.workflows.exceptions.ExecutorException

Raised when subprocess execution fails.

Process class Exception :param list command: child process command :param str message: custom message :param str stderr: child process stderr :param str stdout: child process stdout :param int return_code: child process exit code

explanation

Describes the error in detail

exception aria.orchestrator.workflows.exceptions.TaskCreationException

Bases: aria.orchestrator.workflows.exceptions.TaskException

Could not create the task.

exception aria.orchestrator.workflows.exceptions.TaskException

Bases: aria.exceptions.AriaError

Raised by the task.

aria.orchestrator.workflows.core.graph_compiler

class aria.orchestrator.workflows.core.graph_compiler.GraphCompiler(ctx, default_executor)

Bases: object

compile(task_graph, start_stub_type=’start_workflow’, end_stub_type=’end_workflow’, depends_on=())

Translates the user graph to the execution graph :param task_graph: The user’s graph :param start_stub_type: internal use :param end_stub_type: internal use :param depends_on: internal use

aria.orchestrator.workflows.core.engine

Workflow execution.

class aria.orchestrator.workflows.core.engine.Engine(executors, **kwargs)

Bases: aria.logger.LoggerMixin

Executes workflows.

static cancel_execution(ctx)

Send a cancel request to the engine. If execution already started, execution status will be modified to cancelling status. If execution is in pending mode, execution status will be modified to cancelled directly.

execute(ctx, resuming=False)

Executes the workflow.