hpcflow.app.Submission#

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

Bases: Submission

Methods

from_json_like

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.

submit

Generate and submit the jobscripts of this submission.

to_dict

to_json_like

Attributes

JS_parallelism

abort_EARs_file_name

abort_EARs_file_path

all_EAR_IDs

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 (Optional[app.Workflow]) –

  • submission_attempts (Optional[List]) –

  • JS_parallelism (Optional[bool]) –

property JS_parallelism#
property abort_EARs_file_name#
property abort_EARs_file_path#
property all_EAR_IDs#
app = BaseApp(name='hpcFlow', version='0.2.0a59')#
classmethod from_json_like(json_like, shared_data=None)#
Parameters:
  • json_like (Union[Dict, List]) –

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

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#
property status#
property submission_attempts: List#
submit(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#