core.exceptions

Custom Exceptions used throughout Jobmon.

Exceptions

InvalidResponse

Invalid Response type Exception.

InvalidRequest

Invalid Request type Exception.

RemoteExitInfoNotAvailable

Exception raised when Exit Info is not available for different executor types.

CallableReturnedInvalidObject

Invalid Object got returned.

WorkflowAlreadyExists

Workflow with the same workflow args already exists.

WorkflowAlreadyComplete

This Workflow is already done.

WorkflowNotResumable

This Workflow is not set to be resumed.

EmptyWorkflowError

This Workflow is empty.

DistributorStartupTimeout

Distributor was not able to start in time.

DistributorNotAlive

The Distributor is not running.

DistributorUnexpected

Unexpected situation in Distributor.

WorkflowRunStateError

Error with the Workflow Run status.

ResumeSet

Resume Exception.

NodeDependencyNotExistError

Dependency does not exist.

DuplicateNodeArgsError

Multiple nodes with the same args for the same TaskTemplate not allowed.

InvalidMemoryFormat

Memory input invalid.

InvalidMemoryUnit

Memory convert unit invalid.

ConfigError

No configuration found for server.

InvalidStateTransition

Invalid State Transition implementation.

TransitionError

Transition failed.

WorkflowTestError

Workflow Run encountered and error.

DistributorInterruptedError

raised when signal is sent to distributor.

CyclicGraphError

Cyclic graph detected.

Classes

ReturnCodes

Bash return codes used in distributor wrapper.

Module Contents

class core.exceptions.ReturnCodes[source]

Bases: object

Bash return codes used in distributor wrapper.

OK = 0[source]
WORKER_NODE_ENV_FAILURE = 198[source]
WORKER_NODE_CLI_FAILURE = 199[source]
exception core.exceptions.InvalidResponse[source]

Bases: Exception

Invalid Response type Exception.

exception core.exceptions.InvalidRequest[source]

Bases: Exception

Invalid Request type Exception.

exception core.exceptions.RemoteExitInfoNotAvailable[source]

Bases: Exception

Exception raised when Exit Info is not available for different executor types.

exception core.exceptions.CallableReturnedInvalidObject[source]

Bases: Exception

Invalid Object got returned.

exception core.exceptions.WorkflowAlreadyExists[source]

Bases: Exception

Workflow with the same workflow args already exists.

exception core.exceptions.WorkflowAlreadyComplete[source]

Bases: Exception

This Workflow is already done.

exception core.exceptions.WorkflowNotResumable[source]

Bases: Exception

This Workflow is not set to be resumed.

exception core.exceptions.EmptyWorkflowError[source]

Bases: Exception

This Workflow is empty.

exception core.exceptions.DistributorStartupTimeout[source]

Bases: Exception

Distributor was not able to start in time.

exception core.exceptions.DistributorNotAlive[source]

Bases: Exception

The Distributor is not running.

exception core.exceptions.DistributorUnexpected[source]

Bases: Exception

Unexpected situation in Distributor.

exception core.exceptions.WorkflowRunStateError[source]

Bases: Exception

Error with the Workflow Run status.

exception core.exceptions.ResumeSet[source]

Bases: Exception

Resume Exception.

exception core.exceptions.NodeDependencyNotExistError[source]

Bases: Exception

Dependency does not exist.

exception core.exceptions.DuplicateNodeArgsError[source]

Bases: Exception

Multiple nodes with the same args for the same TaskTemplate not allowed.

exception core.exceptions.InvalidMemoryFormat[source]

Bases: Exception

Memory input invalid.

exception core.exceptions.InvalidMemoryUnit[source]

Bases: Exception

Memory convert unit invalid.

exception core.exceptions.ConfigError[source]

Bases: Exception

No configuration found for server.

exception core.exceptions.InvalidStateTransition(model: str, id: int, old_state: str, new_state: str)[source]

Bases: Exception

Invalid State Transition implementation.

msg[source]
exception core.exceptions.TransitionError[source]

Bases: Exception

Transition failed.

exception core.exceptions.WorkflowTestError[source]

Bases: Exception

Workflow Run encountered and error.

exception core.exceptions.DistributorInterruptedError[source]

Bases: Exception

raised when signal is sent to distributor.

exception core.exceptions.CyclicGraphError[source]

Bases: Exception

Cyclic graph detected.