X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/b7f67c80916c2efa0c234ab5f4e92c24d47223c5..35ade8a042094a27e2ca5cfd5e9754aa3513410c:/services/nodemanager/arvnodeman/timedcallback.py diff --git a/services/nodemanager/arvnodeman/timedcallback.py b/services/nodemanager/arvnodeman/timedcallback.py index a1df8ec17b..615f798f5b 100644 --- a/services/nodemanager/arvnodeman/timedcallback.py +++ b/services/nodemanager/arvnodeman/timedcallback.py @@ -23,8 +23,9 @@ class TimedCallBackActor(actor_class): 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: