Utils

class mosaic.runtime.utils.MonitoredObject(runtime_id, uid, tessera_id=None)[source]

Bases: object

Base class for those that keep track of the state of a Mosaic object,

add_event(runtime_id, event_type, event_name, **kwargs)[source]
add_profile(runtime_id, profile_type, profile)[source]
append(filename=None)[source]
collect()[source]
property state
class mosaic.runtime.utils.MonitoredResource(uid)[source]

Bases: object

Base class for those that keep track of the state of a Mosaic runtime,

add_group(group_name)[source]
add_resource(group_name, name)[source]
append(filename=None)[source]
get_update()[source]
sort_resources(group_name, key, desc=False)[source]
property state
update(update, **kwargs)[source]
class mosaic.runtime.utils.WarehouseObject(obj=None, uid=None)[source]

Bases: object

Represents a reference to an object that is stored into the warehouse.

Parameters

obj (object) – Object being added.

async drop()[source]

Delete object from the warehouse.

property has_tessera
property is_proxy
property is_tessera
async result()[source]

Alias for WarehouseObject.value.

property runtime

Current runtime object.

property state
property uid

UID of the object.

async value()[source]

Pull the underlying value from the warehouse.