From 4b0706380ee87d582dba1e15376ce46b16c42a24 Mon Sep 17 00:00:00 2001 From: Fabio Manganiello Date: Tue, 12 Dec 2017 19:26:23 +0100 Subject: [PATCH] Consistent logging info --- platypush/backend/kafka/__init__.py | 3 +++ platypush/backend/pushbullet/__init__.py | 3 +++ 2 files changed, 6 insertions(+) diff --git a/platypush/backend/kafka/__init__.py b/platypush/backend/kafka/__init__.py index c0fabbfff..9ce04be08 100644 --- a/platypush/backend/kafka/__init__.py +++ b/platypush/backend/kafka/__init__.py @@ -41,6 +41,9 @@ class KafkaBackend(Backend): def run(self): self.consumer = KafkaConsumer(self.topic, bootstrap_servers=self.server) + logging.info('Initialized kafka backend - server: {}, topic: {}' + .format(self.server, self.topic)) + for msg in self.consumer: self._on_record(msg) diff --git a/platypush/backend/pushbullet/__init__.py b/platypush/backend/pushbullet/__init__.py index f42ee9792..3df899db4 100644 --- a/platypush/backend/pushbullet/__init__.py +++ b/platypush/backend/pushbullet/__init__.py @@ -83,6 +83,9 @@ class PushbulletBackend(Backend): def run(self): self._init_socket() + logging.info('Initialized Pushbullet backend - device_id: {}' + .format(self.device)) + self.ws.run_forever() # vim:sw=4:ts=4:et: