Module zoo_calrissian_runner.handlers

Execution Handler for Calrissian/Kubernetes.

Extends CommonExecutionHandler with Calrissian-specific methods.

Classes

class ExecutionHandler(
    **kwargs
)

Extended ExecutionHandler with Calrissian-specific methods.

Inherits from CommonExecutionHandler to provide STAC catalog processing and adds Calrissian/Kubernetes-specific functionality.

def local_get_file(
    fileName
)

Read and load the contents of a yaml file.

def get_additional_parameters(
    self
) -> dict[str, str]

Get additional parameters with eoap storage platform.

def get_namespace(
    self
)

Get the namespace for the execution.

def get_pod_env_vars(
    self
) -> dict[str, str]

Get environment variables for the pod spawned by calrissian.

def get_pod_node_selector(
    self
) -> dict[str, str]

Get node selector for the pod spawned by calrissian.

def get_secrets(
    self
)

Get secrets for the pod spawned by calrissian.

def get_service_account(
    self
)

Get the service account for the execution.

def handle_outputs(
    self,
    log,
    output,
    usage_report,
    tool_logs
)

Handle the output files of the execution and register tool logs.

def post_execution_hook(
    self,
    log,
    output,
    usage_report,
    tool_logs
)

Hook to run after execution. Sets up S3 environment and processes outputs.

def pre_execution_hook(
    self
)

Hook to run before execution. Override in subclasses for custom behavior.

def setOutput(
    self,
    outputName,
    values
)

Process and set output values from STAC catalog.

def set_job_id(
    self,
    job_id
)

Set the job ID for the execution.