Skip to content
Snippets Groups Projects
Commit 3c4a33cc authored by istmxrein's avatar istmxrein
Browse files

refactor logging & bump to 1.2.4

parent 480463b1
No related branches found
No related tags found
No related merge requests found
...@@ -258,7 +258,7 @@ class PowerConsumer(threading.Thread): ...@@ -258,7 +258,7 @@ class PowerConsumer(threading.Thread):
event = Event.parse_obj(json.loads(body.decode('utf-8'))) event = Event.parse_obj(json.loads(body.decode('utf-8')))
self.callback(event) self.callback(event)
self._channel.basic_ack(basic_deliver.delivery_tag) self._channel.basic_ack(basic_deliver.delivery_tag)
logger.info(f"Event processed successful") logger.debug(f"Event processed successful")
except Exception as e: except Exception as e:
traceback.print_exc() traceback.print_exc()
logger.error(f"Failed to process Event; message {e}") logger.error(f"Failed to process Event; message {e}")
...@@ -316,7 +316,6 @@ class PowerConsumer(threading.Thread): ...@@ -316,7 +316,6 @@ class PowerConsumer(threading.Thread):
logger.info('Stopping') logger.info('Stopping')
if self._consuming: if self._consuming:
self.stop_consuming() self.stop_consuming()
self._connection.ioloop.start()
else: else:
self._connection.ioloop.stop() self._connection.ioloop.stop()
logger.info('Stopped') logger.info('Stopped')
...@@ -2,7 +2,7 @@ from setuptools import setup, find_packages ...@@ -2,7 +2,7 @@ from setuptools import setup, find_packages
setup( setup(
name='pilab', name='pilab',
version='1.2.3', version='1.2.4',
description='Shared-Libs for the pi-lab microservices', description='Shared-Libs for the pi-lab microservices',
url='https://code.fbi.h-da.de/api/v4/projects/27896/packages/pypi/pilab', url='https://code.fbi.h-da.de/api/v4/projects/27896/packages/pypi/pilab',
author='Max Reinheimer', author='Max Reinheimer',
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment