[ARVADOS] updated: d1de3281f023bfdbb62a172dec058caf2496224f
Git user
git at public.curoverse.com
Thu Mar 10 15:54:38 EST 2016
Summary of changes:
services/nodemanager/arvnodeman/computenode/dispatch/__init__.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
via d1de3281f023bfdbb62a172dec058caf2496224f (commit)
from 071cbfb5b1b9328d0db5d4e4c07fd0c8d604c39e (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit d1de3281f023bfdbb62a172dec058caf2496224f
Author: Peter Amstutz <peter.amstutz at curoverse.com>
Date: Thu Mar 10 15:54:27 2016 -0500
Fix node manager to send ActorProxy instead of TellActorProxy to
ComputeNodeStateChangeBase subscribers. refs #8543
diff --git a/services/nodemanager/arvnodeman/computenode/dispatch/__init__.py b/services/nodemanager/arvnodeman/computenode/dispatch/__init__.py
index e11dcc7..a239f1f 100644
--- a/services/nodemanager/arvnodeman/computenode/dispatch/__init__.py
+++ b/services/nodemanager/arvnodeman/computenode/dispatch/__init__.py
@@ -39,7 +39,7 @@ class ComputeNodeStateChangeBase(config.actor_class, RetryMixin):
def _finished(self):
if self.subscribers is None:
raise Exception("Actor tried to finish twice")
- _notify_subscribers(self._later, self.subscribers)
+ _notify_subscribers(self.actor_ref.proxy(), self.subscribers)
self.subscribers = None
self._logger.info("finished")
@@ -391,7 +391,7 @@ class ComputeNodeMonitorActor(config.actor_class):
eligible = self.shutdown_eligible()
if eligible is True:
self._debug("Suggesting shutdown.")
- _notify_subscribers(self._later, self.subscribers)
+ _notify_subscribers(self.actor_ref.proxy(), self.subscribers)
elif self._shutdowns.window_open():
self._debug("Cannot shut down because %s", eligible)
elif self.last_shutdown_opening != next_opening:
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list