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)