nvtabular.workflow.workflow.WorkflowNode

class nvtabular.workflow.workflow.WorkflowNode(selector=None)[source]

Bases: merlin.dag.node.Node

WorkflowNode represents a Node in a NVTabular workflow graph

__init__(selector=None)

Methods

__init__([selector])

add_child(child)

Adding a child node to this node

add_dependency(dep)

Adding a dependency node to this node

add_parent(parent)

Adding a parent node to this node

compute_schemas(root_schema[, preserve_dtypes])

Defines the input and output schema

construct_from(nodable)

Convert Node-like objects to a Node or list of Nodes.

export(output_path[, node_id, version])

Export a directory for this node, containing the required artifacts to run in the target context.

exportable([backend])

remove_child(child)

Removing a child node from this node

remove_inputs(input_cols)

Remove input columns and all output columns that depend on them.

validate_schemas(root_schema[, strict_dtypes])

Check if this Node’s input schema matches the output schemas of parents and dependencies

Attributes

column_mapping

dependency_columns

export_name

Name for the exported node directory.

graph

grouped_parents_with_dependencies

input_columns

label

output_columns

parents_with_dependencies

selector