skyline.horizon package¶
Submodules¶
skyline.horizon.listen module¶
-
class
SafeUnpickler
[source]¶ Bases:
object
-
PICKLE_SAFE
= {'__builtin__': set(['object']), 'copy_reg': set(['_reconstructor'])}¶
-
skyline.horizon.roomba module¶
skyline.horizon.worker module¶
-
class
Worker
(queue, parent_pid, skip_mini, canary=False)[source]¶ Bases:
multiprocessing.process.Process
The worker processes chunks from the queue and appends the latest datapoints to their respective timesteps in Redis.