diff --git a/yupana/processor/report_consumer.py b/yupana/processor/report_consumer.py index b11a83c7..962f29ff 100644 --- a/yupana/processor/report_consumer.py +++ b/yupana/processor/report_consumer.py @@ -143,6 +143,7 @@ async def save_message_and_ack(self, consumer_record): 'arrival_time': datetime.now(pytz.utc), 'retry_count': 0 } + LOG.info('Originating Request ID: %s.' % request_id) report_serializer = ReportSerializer(data=uploaded_report) report_serializer.is_valid(raise_exception=True) report_serializer.save()