skyline.horizon package¶
Submodules¶
skyline.horizon.listen module¶
-
class
SafeUnpickler
[source]¶ Bases:
_pickle.Unpickler
-
PICKLE_SAFE
= {'__builtin__': {'object'}, 'copy_reg': {'_reconstructor'}}¶
-
find_class
(module, name)[source]¶ Return an object from a specified module.
If necessary, the module will be imported. Subclasses may override this method (e.g. to restrict unpickling of arbitrary classes and functions).
This method is called whenever a class or a function object is needed. Both arguments passed are str objects.
-
skyline.horizon.roomba module¶
skyline.horizon.worker module¶
worker.py
-
class
Worker
(queue, parent_pid, skip_mini, worker_number, canary=False)[source]¶ Bases:
multiprocessing.context.Process
The worker processes chunks from the queue and appends the latest datapoints to their respective timesteps in Redis.