Module pycalrissian.execution

Classes

class CalrissianExecution(
    job: pycalrissian.job.CalrissianJob,
    runtime_context: pycalrissian.context.CalrissianContext
)

def get_completion_time(
    self
)

Returns either the completion time or the last transition time

def get_file_from_volume(
    self,
    filenames
)

def get_log(
    self
)

Returns the job execution log

def get_output(
    self
) -> Dict

Returns the job output

def get_start_time(
    self
)

Returns the start time

def get_status(
    self
)

Returns the job status

def get_tool_logs(
    self
)

stages the tool logs from k8s volume

def get_usage_report(
    self
) -> Dict

Returns the job usage report

def get_waiting_pods(
    self
) -> List[kubernetes.client.models.v1_pod.V1Pod]

def is_active(
    self
) -> bool

Returns True if the job execution is on-going

def is_complete(
    self
) -> bool

Returns True if the job execution is completed (success or failed)

def is_succeeded(
    self
) -> bool

Returns True if the job execution is completed and succeeded

def monitor(
    self,
    interval: int = 5,
    grace_period=120,
    wall_time: Optional[int] = None
) -> None

def submit(
    self
)

Submits the job to the cluster

class JobStatus(
    *args,
    **kwds
)

Create a collection of name/value pairs.

Example enumeration:

class Color(Enum): ... RED = 1 ... BLUE = 2 ... GREEN = 3

Access them by:

Color.RED

Color(1)

Color['RED']

Enumerations can be iterated over, and know how many members they have:

len(Color) 3

list(Color) [, , ]

Methods can be added to enumerations, and members can have their own attributes -- see the documentation for details.

ACTIVE

FAILED

KILLED

SUCCEEDED

name

value