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.
`UserTaskFunctionError`	Raised when a user's task function raises an exception.

Classes

ReturnCodes

Bash return codes used in distributor wrapper.

Module Contents

class core.exceptions.ReturnCodes

Bases: object

Bash return codes used in distributor wrapper.

OK = 0

WORKER_NODE_ENV_FAILURE = 198

WORKER_NODE_CLI_FAILURE = 199

exception core.exceptions.InvalidResponse

Bases: Exception

Invalid Response type Exception.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.InvalidRequest

Bases: Exception

Invalid Request type Exception.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.RemoteExitInfoNotAvailable

Bases: Exception

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

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.CallableReturnedInvalidObject

Bases: Exception

Invalid Object got returned.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.WorkflowAlreadyExists

Bases: Exception

Workflow with the same workflow args already exists.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.WorkflowAlreadyComplete

Bases: Exception

This Workflow is already done.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.WorkflowNotResumable

Bases: Exception

This Workflow is not set to be resumed.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.EmptyWorkflowError

Bases: Exception

This Workflow is empty.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.DistributorStartupTimeout

Bases: Exception

Distributor was not able to start in time.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.DistributorNotAlive

Bases: Exception

The Distributor is not running.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.DistributorUnexpected

Bases: Exception

Unexpected situation in Distributor.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.WorkflowRunStateError

Bases: Exception

Error with the Workflow Run status.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.ResumeSet

Bases: Exception

Resume Exception.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.NodeDependencyNotExistError

Bases: Exception

Dependency does not exist.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.DuplicateNodeArgsError

Bases: Exception

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

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.InvalidMemoryFormat

Bases: Exception

Memory input invalid.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.InvalidMemoryUnit

Bases: Exception

Memory convert unit invalid.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.ConfigError

Bases: Exception

No configuration found for server.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.InvalidStateTransition(model: str, id: int, old_state: str, new_state: str)

Bases: Exception

Invalid State Transition implementation.

Initialize Exception.

exception core.exceptions.TransitionError

Bases: Exception

Transition failed.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.WorkflowTestError

Bases: Exception

Workflow Run encountered and error.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.DistributorInterruptedError

Bases: Exception

raised when signal is sent to distributor.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.CyclicGraphError

Bases: Exception

Cyclic graph detected.

Initialize self. See help(type(self)) for accurate signature.

exception core.exceptions.UserTaskFunctionError

Bases: Exception

Raised when a user’s task function raises an exception.

Used as a marker to distinguish user task failures from jobmon-internal errors at log boundaries. The original exception is chained via raise ... from e so the full traceback is preserved.

Initialize self. See help(type(self)) for accurate signature.