X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/8709ef45c968e79b5e5978759484b994d4789aea..3af6db5dc4e2f08b2ebb49a82109c4325ad7fcc4:/services/nodemanager/arvnodeman/clientactor.py diff --git a/services/nodemanager/arvnodeman/clientactor.py b/services/nodemanager/arvnodeman/clientactor.py index e5534c53f7..e1307494ec 100644 --- a/services/nodemanager/arvnodeman/clientactor.py +++ b/services/nodemanager/arvnodeman/clientactor.py @@ -38,7 +38,7 @@ class RemotePollLoopActor(actor_class): super(RemotePollLoopActor, self).__init__() self._client = client self._timer = timer_actor - self._later = self.actor_ref.proxy() + self._later = self.actor_ref.tell_proxy() self._polling_started = False self.min_poll_wait = poll_wait self.max_poll_wait = max_poll_wait @@ -72,7 +72,6 @@ class RemotePollLoopActor(actor_class): raise NotImplementedError("subclasses must implement request method") def _got_response(self, response): - self._logger.debug("got response with %d items", len(response)) self.poll_wait = self.min_poll_wait _notify_subscribers(response, self.all_subscribers) if hasattr(self, '_item_key'): @@ -105,7 +104,9 @@ class RemotePollLoopActor(actor_class): else: self._got_response(response) next_poll = scheduled_start + self.poll_wait - self._logger.info("request took %s seconds", (time.time() - scheduled_start)) + self._logger.info("got response with %d items in %s seconds, next poll at %s", + len(response), (time.time() - scheduled_start), + time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(next_poll))) end_time = time.time() if next_poll < end_time: # We've drifted too much; start fresh. next_poll = end_time + self.poll_wait