hpcflow.app.Submission

class hpcflow.app.Submission(index, jobscripts, workflow, submission_attempts=None, JS_parallelism=None)

Bases: Submission

Methods

from_json_like
get_EAR_run_dirs
get_unique_schedulers	Get a unique schedulers and which jobscripts they correspond to.
get_unique_shells	Get unique shells and which jobscripts they correspond to.
prepare_EAR_submission_idx_update	For all EARs in this submission (across all jobscripts), return a tuple of indices that can be passed to Workflow.set_EAR_submission_index.
submit	Generate and submit the jobscripts of this submission.
to_dict
to_json_like

Attributes

JS_parallelism
app
index
jobscript_indices	All associated jobscript indices.
jobscripts
needs_submit
outstanding_jobscripts	Jobscript indices that have not yet been successfully submitted.
path
status
submission_attempts
submitted_jobscripts	Jobscript indices that have been successfully submitted.
workflow

Parameters:

• index (int) –

• jobscripts (List[app.Jobscript]) –

• workflow (app.Workflow) –

• submission_attempts (Optional[List]) –

• JS_parallelism (Optional[bool]) –

property JS_parallelism

app = BaseApp(name='hpcFlow', version='0.2.0a45')

classmethod from_json_like(json_like, shared_data=None)

Parameters:

• json_like (Union[Dict, List]) –

• shared_data (Optional[Dict[str, ObjectList]]) –

get_EAR_run_dirs()

Return type:

Dict[Tuple(int, int, int), Path]

get_unique_schedulers()

Get a unique schedulers and which jobscripts they correspond to.

Return type:

Dict[Tuple[int], Scheduler]

get_unique_shells()

Get unique shells and which jobscripts they correspond to.

Return type:

Dict[Tuple[int], Shell]

property index: int

property jobscript_indices: Tuple[int]

All associated jobscript indices.

property jobscripts: List

property needs_submit

property outstanding_jobscripts: Tuple[int]

Jobscript indices that have not yet been successfully submitted.

property path

prepare_EAR_submission_idx_update()

For all EARs in this submission (across all jobscripts), return a tuple of indices that can be passed to Workflow.set_EAR_submission_index.

Return type:

List[Tuple[int, int, int, int]]

property status

property submission_attempts: List

submit(task_artifacts_path, ignore_errors=False, print_stdout=False)

Generate and submit the jobscripts of this submission.

Return type:

List[int]

property submitted_jobscripts: Tuple[int]

Jobscript indices that have been successfully submitted.

to_dict()

to_json_like(dct=None, shared_data=None, exclude=None, path=None)

property workflow: List