logging.info needs backport

Author: hjwp

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 = []
-

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)))

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)