From ef7b721843f4577ec96763be1001f6be68efe4c1 Mon Sep 17 00:00:00 2001 From: Alexey Velikiy Date: Fri, 17 Jul 2020 22:10:30 +0200 Subject: [PATCH] run_until_run_thread_complete --- analytics/utils/concurrent.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/analytics/utils/concurrent.py b/analytics/utils/concurrent.py index eb89342..19a87f5 100755 --- a/analytics/utils/concurrent.py +++ b/analytics/utils/concurrent.py @@ -140,9 +140,9 @@ class AsyncZmqActor(AsyncZmqThread): ``` """ - def __init__(self, run_until_complete: bool = True): + def __init__(self, run_until_run_thread_complete: bool = True): super(AsyncZmqActor, self).__init__( - run_until_complete, zmq.asyncio.Context(), ZMQ_THREAD_ACTOR_ADDR + run_until_run_thread_complete, zmq.asyncio.Context(), ZMQ_THREAD_ACTOR_ADDR ) self.__actor_socket = self._zmq_context.socket(zmq.PAIR)