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

1"""Definitions of custom :doc:`Celery signals <celery:userguide/signals>` 

2related to Kafka messages. 

3""" 

4from celery.utils.dispatch import Signal 

5 

6kafka_record_consumed = Signal( 

7 name='kafka_record_consumed', providing_args=('name', 'record')) 

8"""Fired whenever a Kafka record is received. 

9 

10Parameters 

11---------- 

12name : str 

13 The name (key) of the Kafka configuration associated with the topic the 

14 message was received from, e.g. ``fermi_swift``. 

15record : dict 

16 The deserialized contents of the message. 

17"""