hpcflow.sdk.persistence.zarr.ZarrStoreTask#

class hpcflow.sdk.persistence.zarr.ZarrStoreTask(id_: 'int', index: 'int', is_pending: 'bool', element_IDs: 'List[int]', task_template: 'Optional[Dict]' = None)#

Bases: StoreTask

Methods

append_element_IDs

Return a copy, with additional element IDs.

decode

Initialise a StoreTask from persistent task data

encode

Prepare store task data for the persistent store.

Attributes

task_template

id_

index

is_pending

element_IDs

Parameters:

  • id_ (int) –

  • index (int) –

  • is_pending (bool) –

  • element_IDs (List[int]) –

  • task_template (Dict | None) –

append_element_IDs(pend_IDs)#

Return a copy, with additional element IDs.

Parameters:

  • self (AnySTask) –

  • pend_IDs (List[int]) –

Return type:

AnySTask

classmethod decode(task_dat)#

Initialise a StoreTask from persistent task data

Parameters:

task_dat (Dict) –

Return type:

ZarrStoreTask

element_IDs: List[int]#
encode()#

Prepare store task data for the persistent store.

Return type:

Tuple[int, ndarray, Dict]

id_: int#
index: int#
is_pending: bool#
task_template: Dict | None = None#