asset_store#

class predict_backend.store.asset_store.AssetStore#

Bases: Store

We should separate the DataStoreHandler from the Store class here.

delete_asset(asset)#
delete_asset_record(label, type, time_created)#
get_any_asset_data(label=None, type=None, name=None)#
get_asset_data(label, asset_type, name=None, time_created=None)#
Parameters:

  • label (str) –

  • asset_type (AssetType) –

  • name (Optional[str]) –

  • time_created (Optional[str]) –

Returns:

static get_asset_key(label, type)#
get_asset_record(label, asset_type, name=None, time_created=None)#
Return type:

dict

get_asset_record_metadata(label, type, name=None, time_created=None)#
get_asset_records(label=None, asset_type=None, name=None)#

Full coverage for this function is provided in integration tests. Get asset records by the compound key only if possible (get_items_by_key) otherwise get records by a combination of key and attributes (get_items_by_attributes) which is not coverable by unit tests and maybe a little bit slower

Parameters:

  • label (Optional[str]) –

  • asset_type (Optional[AssetType]) –

  • name (Optional[str]) –

Return type:

List[dict]

Returns:

get_asset_records_metadata(label=None, type=None, name=None)#
make_asset_record(asset, flow_data, persistence, origin='')#
make_free_asset_record(asset, persistence)#
name = 'asset'#
save_asset_data(asset, flow_data, persistence, origin='')#
save_free_asset_data(asset, persistence)#