hpcflow.sdk.persistence.zarr.ZarrStoreEAR#

class hpcflow.sdk.persistence.zarr.ZarrStoreEAR(id_: 'int', is_pending: 'bool', elem_iter_ID: 'int', action_idx: 'int', data_idx: 'Dict[str, int]', submission_idx: 'Optional[int]' = None, skip: 'Optional[bool]' = False, success: 'Optional[bool]' = None, start_time: 'Optional[datetime]' = None, end_time: 'Optional[datetime]' = None, snapshot_start: 'Optional[Dict]' = None, snapshot_end: 'Optional[Dict]' = None, exit_code: 'Optional[int]' = None, metadata: 'Dict[str, Any]' = None)#

Bases: StoreEAR

Methods

decode

Initialise a ZarrStoreEAR from persistent EAR data

encode

Prepare store EAR data for the persistent store.

to_dict

Prepare data for the user-facing ElementActionRun object.

update

Return a shallow copy, with specified data updated.

Attributes

end_time

exit_code

metadata

skip

snapshot_end

snapshot_start

start_time

submission_idx

success

id_

is_pending

elem_iter_ID

action_idx

data_idx

Parameters:
  • id_ (int) –

  • is_pending (bool) –

  • elem_iter_ID (int) –

  • action_idx (int) –

  • data_idx (Dict[str, int]) –

  • submission_idx (int | None) –

  • skip (bool | None) –

  • success (bool | None) –

  • start_time (datetime | None) –

  • end_time (datetime | None) –

  • snapshot_start (Dict | None) –

  • snapshot_end (Dict | None) –

  • exit_code (int | None) –

  • metadata (Dict[str, Any]) –

action_idx: int#
data_idx: Dict[str, int]#
classmethod decode(EAR_dat, attrs, ts_fmt)#

Initialise a ZarrStoreEAR from persistent EAR data

Parameters:
Return type:

ZarrStoreEAR

elem_iter_ID: int#
encode(attrs, ts_fmt)#

Prepare store EAR data for the persistent store.

This method mutates attrs.

Parameters:
  • attrs (Dict) –

  • ts_fmt (str) –

Return type:

Tuple[List, Tuple[datetime64]]

end_time: datetime | None = None#
exit_code: int | None = None#
id_: int#
is_pending: bool#
metadata: Dict[str, Any] = None#
skip: bool | None = False#
snapshot_end: Dict | None = None#
snapshot_start: Dict | None = None#
start_time: datetime | None = None#
submission_idx: int | None = None#
success: bool | None = None#
to_dict()#

Prepare data for the user-facing ElementActionRun object.

Return type:

Dict

update(submission_idx=None, skip=None, success=None, start_time=None, end_time=None, snapshot_start=None, snapshot_end=None, exit_code=None)#

Return a shallow copy, with specified data updated.

Parameters:
  • submission_idx (int | None) –

  • skip (bool | None) –

  • success (bool | None) –

  • start_time (datetime | None) –

  • end_time (datetime | None) –

  • snapshot_start (Dict | None) –

  • snapshot_end (Dict | None) –

  • exit_code (int | None) –

Return type:

AnySEAR