[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