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

1"""Embed a Kafka producer into a Celery worker by 

2:doc:`extending Celery with bootsteps <celery:userguide/extending>`. 

3""" 

4from .bootsteps import Consumer, Producer 

5 

6 

7def install(app): 

8 """Register the Kafka subsystem in the application boot steps.""" 

9 app.steps['consumer'] |= {Producer, Consumer}