1def consume(channel):
2 for method, properties, body in channel.consume('invoices'):
3 channel.basic_ack(method.delivery_tag)
4 payload = json.loads(body)
5 generate_invoice_pdf(payload)
6 upload_to_s3(payload['invoice_id'])
no lines flagged
#117PracticeMedium14 min · 120 XP
Message Acknowledged Before It Is Processed
During a deploy, a handful of invoices simply never get generated. There is no error in the logs and the queue is empty.
Flagged linesNo lines flagged yet
Flag a line or write a note to submit.