core.constants

Constants declared for different statuses, types and codes throughout Jobmon.

Classes

ArgType

TaskResourcesType

Constant Types for Task Resources.

TaskInstanceStatus

Statuses used for Task Instances.

TaskStatus

Statuses used for Tasks.

WorkflowRunStatus

Statuses used for Workflow Runs.

WorkflowStatus

Statuses used for Workflows.

Direction

A generic utility class.

SpecialChars

A generic utility class.

ExecludeTTVs

A hard-coded list.

MaxConcurrentlyRunning

A hard limit of array concurrency.

Module Contents

class core.constants.ArgType[source]
NODE_ARG = 1[source]
TASK_ARG = 2[source]
OP_ARG = 3[source]
class core.constants.TaskResourcesType[source]

Constant Types for Task Resources.

ORIGINAL = 'O'[source]
VALIDATED = 'V'[source]
ADJUSTED = 'A'[source]
class core.constants.TaskInstanceStatus[source]

Statuses used for Task Instances.

DONE = 'D'[source]
ERROR = 'E'[source]
ERROR_FATAL = 'F'[source]
INSTANTIATED = 'I'[source]
KILL_SELF = 'K'[source]
LAUNCHED = 'O'[source]
QUEUED = 'Q'[source]
RUNNING = 'R'[source]
TRIAGING = 'T'[source]
SUBMITTED_TO_BATCH_DISTRIBUTOR = 'B'[source]
UNKNOWN_ERROR = 'U'[source]
NO_DISTRIBUTOR_ID = 'W'[source]
NO_HEARTBEAT = 'X'[source]
RESOURCE_ERROR = 'Z'[source]
class core.constants.TaskStatus[source]

Statuses used for Tasks.

REGISTERING = 'G'[source]
QUEUED = 'Q'[source]
INSTANTIATING = 'I'[source]
LAUNCHED = 'O'[source]
RUNNING = 'R'[source]
DONE = 'D'[source]
ERROR_RECOVERABLE = 'E'[source]
ADJUSTING_RESOURCES = 'A'[source]
ERROR_FATAL = 'F'[source]
LABEL_DICT[source]
class core.constants.WorkflowRunStatus[source]

Statuses used for Workflow Runs.

REGISTERED = 'G'[source]
LINKING = 'L'[source]
BOUND = 'B'[source]
ABORTED = 'A'[source]
RUNNING = 'R'[source]
DONE = 'D'[source]
STOPPED = 'S'[source]
ERROR = 'E'[source]
COLD_RESUME = 'C'[source]
HOT_RESUME = 'H'[source]
TERMINATED = 'T'[source]
INSTANTIATED = 'I'[source]
LAUNCHED = 'O'[source]
class core.constants.WorkflowStatus[source]

Statuses used for Workflows.

REGISTERING = 'G'[source]
QUEUED = 'Q'[source]
ABORTED = 'A'[source]
INSTANTIATING = 'I'[source]
LAUNCHED = 'O'[source]
RUNNING = 'R'[source]
DONE = 'D'[source]
HALTED = 'H'[source]
FAILED = 'F'[source]
class core.constants.Direction[source]

Bases: enum.Enum

A generic utility class.

Used to represent one-dimensional direction, such as upstream/downstream.

UP = 'up'[source]
DOWN = 'down'[source]
class core.constants.SpecialChars[source]

A generic utility class.

Used to define special chars.

ILLEGAL_SPECIAL_CHARACTERS = '/\\\\\'\\" '[source]
class core.constants.ExecludeTTVs[source]

A hard-coded list.

Used to exclude task template versions with huge tasks that cause DB crash.

EXECLUDE_TTVS[source]
class core.constants.MaxConcurrentlyRunning[source]

A hard limit of array concurrency.

Currently set to max int, but can change as INFRA requests.

MAXCONCURRENTLYRUNNING = 2147483647[source]