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

3 statements  

« prev     ^ index     » next       coverage.py v7.4.2, created at 2024-03-28 17:21 +0000

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}