Fix node manager to send ActorProxy instead of TellActorProxy to
authorPeter Amstutz <peter.amstutz@curoverse.com>
Thu, 10 Mar 2016 20:54:27 +0000 (15:54 -0500)
committerPeter Amstutz <peter.amstutz@curoverse.com>
Thu, 10 Mar 2016 20:54:27 +0000 (15:54 -0500)
ComputeNodeStateChangeBase subscribers.  refs #8543

services/nodemanager/arvnodeman/computenode/dispatch/__init__.py

index e11dcc77badbe58de0b56cec9d04e1316d79d2a6..a239f1f252b5998d4e38a7bddbb0d7d4acdec3b3 100644 (file)
@@ -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: