Source code for radical.utils.queue_network.node


__author__    = "Radical.Utils Development Team"
__copyright__ = "Copyright 2018, RADICAL"
__license__   = "GPL"


"""
Provide an abstract base class for a component of a distributed queue network.
The node can exist either as thread, as a local process, or as a remote process,
spawned via SAGA.  The communication between nodes is always via queues, were
groups of nodes feed into the same queues, and/or are fed from the same queues.
A node can be fed from multiple queues, where queues are prioritized according
to some policy.
"""


# ------------------------------------------------------------------------------
#
[docs] class Node(object): pass
# ------------------------------------------------------------------------------