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,
    destination_path='.'
)

stages the files from k8s volume

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: Union[int, NoneType] = None
) -> None

Monitors the job execution and waits for it to complete

def submit(
    self
)

Submits the job to the cluster

class JobStatus(
    /,
    *args,
    **kwargs
)

An enumeration.

ACTIVE

FAILED

KILLED

SUCCEEDED

name

value