@@ -0,0 +1,612 @@
+import logging%0A%0Afrom flow.orchestrator.redisom import get_object%0A%0ALOG = logging.getLogger(__name__)%0A%0Aclass OrchestratorNodeHandler(object):%0A    def __init__(self, redis=None, services=None, callback_name=None):%0A        assert(callback_name in%0A                set(%5B'on_ready', 'on_start', 'on_success', 'on_failure'%5D))%0A        self.redis = redis%0A        self.services = services%0A        self.callback_name = callback_name%0A%0A    def message_handler(self, message):%0A        node = get_object(self.redis, message.return_identifier)%0A        callback = getattr(node, self.callback_name)%0A        callback(self.services)%0A

add orchestrator node handler sketch