hpcflow.sdk.persistence.zarr.ZarrStoreEAR

class hpcflow.sdk.persistence.zarr.ZarrStoreEAR(id_: 'int', is_pending: 'bool', elem_iter_ID: 'int', action_idx: 'int', commands_idx: 'List[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, run_hostname: 'Optional[str]' = 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
run_hostname
skip
snapshot_end
snapshot_start
start_time
submission_idx
success
id_
is_pending
elem_iter_ID
action_idx
commands_idx
data_idx

Parameters:

• id_ (int) –

• is_pending (bool) –

• elem_iter_ID (int) –

• action_idx (int) –

• commands_idx (List[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]) –

• run_hostname (str | None) –

action_idx: int

commands_idx: List[int]

data_idx: Dict[str, int]

classmethod decode(EAR_dat, attrs, ts_fmt)

Initialise a ZarrStoreEAR from persistent EAR data

Parameters:

• EAR_dat (List) –

• attrs (Dict) –

• ts_fmt (str) –

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

run_hostname: str | None = 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, run_hostname=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) –

• run_hostname (str | None) –

Return type:

AnySEAR