Coverage for gwcelery/voevent/__init__.py: 100%

1"""Embed a :doc:`comet:index` VOEvent broker and subscriber into a Celery 

2worker by :doc:`extending Celery with bootsteps 

3<celery:userguide/extending>`. 

4""" 

5from .bootsteps import Broadcaster, Reactor, Receiver 

6 

7 

8def install(app): 

9 """Register the VOEvent subsystem in the application boot steps.""" 

10 app.steps['consumer'] |= {Reactor, Broadcaster, Receiver}