client.node

A node represents an individual task within a DAG.

Attributes

logger

Classes

Node	A node represents an individual task within a Dag.

Module Contents

client.node.logger

class client.node.Node(task_template_version: jobmon.client.task_template_version.TaskTemplateVersion, node_args: Dict[str, Any], requester: jobmon.core.requester.Requester | None = None)

A node represents an individual task within a Dag.

_node_id: int | None = None

task_template_version

node_args

mapped_node_args

node_args_hash = 0

upstream_nodes: Set[Node]

downstream_nodes: Set[Node]

requester = None

property node_id: int

Unique id for each node.

property task_template_version_id: int

property default_name: str

The default name of this node in the array.

_hash_node_args() → int

A hash of the node.

The hash is the encoded result of the args and values concatenated together.

add_upstream_node(upstream_node: Node) → None

Add a single node to this one’s upstream Nodes.

Parameters:

upstream_node – node to add a dependency on

add_upstream_nodes(upstream_nodes: List[Node]) → None

Add many nodes to this one’s upstream Nodes.

Parameters:

upstream_nodes – list of nodes to add dependencies on

add_downstream_node(downstream_node: Node) → None

Add a node to this one’s downstream Nodes.

Parameters:

downstream_node – Node that will be dependent on this node

add_downstream_nodes(downstream_nodes: List[Node]) → None

Add a list of nodes as this node’s downstream nodes.

Parameters:

downstream_nodes – Nodes that will be dependent on this node.

__repr__() → str

Repr the node attributes.

__eq__(other: object) → bool

Check if two nodes have equal hashes.

__lt__(other: Node) → bool

Check if this hash is less than anothers.

__hash__() → int

Create a hash that will be a unique identifier for the node.