logging.info needs backport

hjwp · hjwp · commit 24b9c2f70438 · 2020-03-05T19:59:44.000Z
diff --git a/src/allocation/adapters/orm.py b/src/allocation/adapters/orm.py
@@ -1,3 +1,4 @@
+import logging
 from sqlalchemy import (
     Table, MetaData, Column, Integer, String, Date, ForeignKey,
     event,
@@ -6,6 +7,7 @@
 
 from allocation.domain import model
 
+logger = logging.getLogger(__name__)
 
 metadata = MetaData()
 
@@ -48,6 +50,7 @@
 
 
 def start_mappers():
+    logger.info("Starting mappers")
     lines_mapper = mapper(model.OrderLine, order_lines)
     batches_mapper = mapper(model.Batch, batches, properties={
         '_allocations': relationship(
@@ -63,4 +66,3 @@ def start_mappers():
 @event.listens_for(model.Product, 'load')
 def receive_load(product, _):
     product.events = []
-
diff --git a/src/allocation/adapters/redis_eventpublisher.py b/src/allocation/adapters/redis_eventpublisher.py
@@ -12,5 +12,5 @@
 
 
 def publish(channel, event: events.Event):
-    logging.debug('publishing: channel=%s, event=%s', channel, event)
+    logging.info('publishing: channel=%s, event=%s', channel, event)
     r.publish(channel, json.dumps(asdict(event)))
diff --git a/src/allocation/entrypoints/redis_eventconsumer.py b/src/allocation/entrypoints/redis_eventconsumer.py
@@ -12,6 +12,7 @@
 
 
 def main():
+    logger.info('Redis pubsub starting')
     bus = bootstrap.bootstrap()
     pubsub = r.pubsub(ignore_subscribe_messages=True)
     pubsub.subscribe('change_batch_quantity')
@@ -21,7 +22,7 @@ def main():
 
 
 def handle_change_batch_quantity(m, bus):
-    logging.debug('handling %s', m)
+    logger.info('handling %s', m)
     data = json.loads(m['data'])
     cmd = commands.ChangeBatchQuantity(ref=data['batchref'], qty=data['qty'])
     bus.handle(cmd)
