improv.replayer#
Module Contents#
Classes#
- class improv.replayer.Replayer(*args, lmdb_path, replay: str, resave=False, **kwargs)#
Bases:
nexus.actor.Actor- get_lmdb_values(replay: str, func: Callable = None) List[nexus.store.LMDBData]#
Load saved queue objects from LMDB
- Parameters:
replay – named of Actor
func – (optional) Function to apply to objects before returning
- Returns:
lmdb_values
- setup()#
- move_to_plasma(lmdb_values)#
Put objects into current plasma store and update object ID in saved queue.
- Parameters:
lmdb_values –
- put_setup(lmdb_values)#
Put all objects created before Run into queue immediately.
- Parameters:
lmdb_values –
- run()#
- runner()#
Get list of objects and output them to their respective queues based on time delay.