@classmethod
def register_node(cls, node):
    """
        Register a node that was scheduled
        :param node: flow to be tracked
        """
    from celery.result import AsyncResult
    from selinon.dispatcher import Dispatcher
    if isinstance(node, Dispatcher):
        cls._flow_instances.append(node)
    else:
        cls._task_instances.append(node)
    AsyncResult.set_unfinished(node.task_id)
