Marmelator/pyinfra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 36 Wiki Activity

removed todo comment

Browse Source
This commit is contained in:
Matthias Bisping 2022-02-17 16:22:36 +01:00
parent 4459f87c6e
commit 820815870f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pyinfra/callback.py
View File

@ -56,7 +56,7 @@ def make_callback_for_output_queue(json_wrapped_body_processor, output_queue_nam
def callback(channel, method, _, body):
result = json_wrapped_body_processor(body) # TODO: retries and stuff; see above
result = json_wrapped_body_processor(body)
channel.basic_publish(exchange="", routing_key=output_queue_name, body=result)
channel.basic_ack(delivery_tag=method.delivery_tag)