From 819b796789e3b70f237749efc4b12322a4783ff2 Mon Sep 17 00:00:00 2001
From: beckerfy <fynn.becker@hs-hannover.de>
Date: Tue, 30 Apr 2019 18:40:53 +0200
Subject: [PATCH] Rename method to work with update pika
---
pikatasks/__init__.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pikatasks/__init__.py b/pikatasks/__init__.py
index 675b278..10477ab 100644
--- a/pikatasks/__init__.py
+++ b/pikatasks/__init__.py
@@ -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
--
GitLab