X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/b7f67c80916c2efa0c234ab5f4e92c24d47223c5..795125d3d998bc1fdbaf31d7d3dd048564f8e685:/services/nodemanager/arvnodeman/timedcallback.py diff --git a/services/nodemanager/arvnodeman/timedcallback.py b/services/nodemanager/arvnodeman/timedcallback.py index a1df8ec17b..12d6280873 100644 --- a/services/nodemanager/arvnodeman/timedcallback.py +++ b/services/nodemanager/arvnodeman/timedcallback.py @@ -18,13 +18,14 @@ class TimedCallBackActor(actor_class): """ def __init__(self, max_sleep=1): super(TimedCallBackActor, self).__init__() - self._proxy = self.actor_ref.proxy() + self._proxy = self.actor_ref.tell_proxy() self.messages = [] self.max_sleep = max_sleep def schedule(self, delivery_time, receiver, *args, **kwargs): + if not self.messages: + self._proxy.deliver() heapq.heappush(self.messages, (delivery_time, receiver, args, kwargs)) - self._proxy.deliver() def deliver(self): if not self.messages: