skyline.horizon package
Submodules
skyline.horizon.agent module
skyline.horizon.listen module
listen.py
- class SafeUnpickler(file, *, fix_imports=True, encoding='ASCII', errors='strict', buffers=())[source]
Bases:
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.prometheus module
prometheus.py
- class PrometheusMetrics(parent_pid)[source]
Bases:
Process
The PrometheusMetrics process is responsible for getting metrics submitted to flux from the flux.prometheus_metrics Redis hash set and adding them to the Horizon worker queue to be submitted to Redis.
skyline.horizon.roomba module
skyline.horizon.worker module
worker.py
- class Worker(queue, parent_pid, skip_mini, worker_number, canary=False)[source]
Bases:
Process
The worker processes chunks from the queue and appends the latest datapoints to their respective timesteps in Redis.