diff --git a/gwcelery/data/gwcelery.sub b/gwcelery/data/gwcelery.sub index 36b65090a819c72cef36e7e26b9951263e019c6f..defedc78bf84502522be69459cc64422a9d0a05e 100755 --- a/gwcelery/data/gwcelery.sub +++ b/gwcelery/data/gwcelery.sub @@ -26,6 +26,10 @@ arguments = "gwcelery worker -l info -n gwcelery-worker@%h -f %n.log -Q celery - description = gwcelery-worker queue +arguments = "gwcelery worker -l info -n gwcelery-kafka-worker@%h -f %n.log -Q kafka --kafka -c 1 --prefetch-multiplier 1" +description = gwcelery-kafka-worker +queue + arguments = "gwcelery worker -l info -n gwcelery-exttrig-worker@%h -f %n.log -Q exttrig -c 1" description = gwcelery-exttrig-worker queue diff --git a/gwcelery/kafka/bootsteps.py b/gwcelery/kafka/bootsteps.py index 7973a0d86a6b3c474906d64ab531c8b31fc86612..f9a86e229c7e1183ef1d92c5ca9aaece5875054c 100644 --- a/gwcelery/kafka/bootsteps.py +++ b/gwcelery/kafka/bootsteps.py @@ -27,6 +27,7 @@ class KafkaBootStep(bootsteps.ConsumerStep): log.info(f'Starting {self.name}, topic: {self.topic_url}') def stop(self, parent): + super().stop(parent) log.info(f'Closing connection to topic: {self.topic_url}')