Skip to content
Snippets Groups Projects
Commit 819b7967 authored by Fynn Becker's avatar Fynn Becker :crab:
Browse files

Rename method to work with update pika

parent c5becf88
No related branches found
No related tags found
No related merge requests found
......@@ -112,7 +112,7 @@ def rpc(_task_name, **kwargs):
expiration=str(int(settings.RPC_TIMEOUT.total_seconds() * 1000)), # in milliseconds, int as str; expire the message so this RPC will not get remotely executed like years later
))
# ask to run the timeout function soon
conn.add_timeout(settings.RPC_TIMEOUT.total_seconds(), callback_timeout)
conn.call_later(settings.RPC_TIMEOUT.total_seconds(), callback_timeout)
# consume, which will be stopped by either callback
channel.start_consuming()
channel.close() # after stopped consuming by either of the callbacks
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment