graph – Interface for the PyTensor graph#
Core graph classes.
- class pytensor.graph.basic.Apply(op, inputs, outputs)[source]#
A
Noderepresenting the application of an operation to inputs.Basically, an
Applyinstance is an object that represents the Python statementoutputs = op(*inputs).This class is typically instantiated by a
Op.make_nodemethod, which is called byOp.__call__.The function
pytensor.compile.function.functionusesApply.inputstogether withVariable.ownerto search the expression graph and determine which inputs are necessary to compute the function’s outputs.A
Linkeruses theApplyinstance’sopfield to compute numeric values for the output variables.Notes
The
Variable.ownerfield of eachApply.outputselement is set toselfinApply.make_node.If an output element has an owner that is neither
Nonenorself, then aValueErrorexception will be raised.- clone(clone_inner_graph=False)[source]#
Clone this
Applyinstance.- Parameters:
clone_inner_graph – If
True, cloneHasInnerGraphOps and their inner-graphs.- Return type:
A new
Applyinstance with new outputs.
Notes
Tags are copied from
selfto the returned instance.
- clone_with_new_inputs(inputs, strict=True, clone_inner_graph=False)[source]#
Duplicate this
Applyinstance in a new graph.- Parameters:
inputs (list of Variables) – List of
Variableinstances to use as inputs.strict (bool) – If
True, the type fields of all the inputs must be equal to the current ones (or compatible, for instanceTensorTypeof the same dtype and broadcastable patterns, in which case they will be converted into currentType), and returned outputs are guaranteed to have the same types asself.outputs. IfFalse, then there’s no guarantee that the clone’s outputs will have the same types asself.outputs, and cloning may not even be possible (it depends on theOp).clone_inner_graph (bool) – If
True, cloneHasInnerGraphOps and their inner-graphs.
- Returns:
An
Applyinstance with the sameOpbut different outputs.- Return type:
object
- default_output()[source]#
Returns the default output for this node.
- Returns:
An element of self.outputs, typically self.outputs[0].
- Return type:
Variable instance
Notes
May raise AttributeError self.op.default_output is out of range, or if there are multiple outputs and self.op.default_output does not exist.
- class pytensor.graph.basic.AtomicVariable(type, name=None, **kwargs)[source]#
A node type that has no ancestors and should never be considered an input to a graph.
- clone(**kwargs)[source]#
Return a new, un-owned
Variablelikeself.- Parameters:
**kwargs (dict) – Optional “name” keyword argument for the copied instance. Same as
self.nameif value not provided.- Returns:
A new
Variableinstance with no owner or index.- Return type:
Variable instance
Notes
Tags and names are copied to the returned instance.
- class pytensor.graph.basic.Constant(type, data, name=None)[source]#
A
Variablewith a fixeddatafield.Constantnodes make numerous optimizations possible (e.g. constant in-lining in C code, constant folding, etc.)Notes
The data field is filtered by what is provided in the constructor for the
Constant’s type field.- clone(**kwargs)[source]#
Return a new, un-owned
Variablelikeself.- Parameters:
**kwargs (dict) – Optional “name” keyword argument for the copied instance. Same as
self.nameif value not provided.- Returns:
A new
Variableinstance with no owner or index.- Return type:
Variable instance
Notes
Tags and names are copied to the returned instance.
- class pytensor.graph.basic.Node[source]#
A
Nodein an PyTensor graph.Currently, graphs contain two kinds of
Nodes:Variables andApplys. Edges in the graph are not explicitly represented. Instead eachNodekeeps track of its parents viaVariable.owner/Apply.inputs.
- class pytensor.graph.basic.NominalVariable(id, typ, **kwargs)[source]#
A variable that enables alpha-equivalent comparisons.
- clone(**kwargs)[source]#
Return a new, un-owned
Variablelikeself.- Parameters:
**kwargs (dict) – Optional “name” keyword argument for the copied instance. Same as
self.nameif value not provided.- Returns:
A new
Variableinstance with no owner or index.- Return type:
Variable instance
Notes
Tags and names are copied to the returned instance.
- class pytensor.graph.basic.Variable(type, owner, index=None, name=None)[source]#
A Variable is a node in an expression graph that represents a variable.
The inputs and outputs of every
ApplyareVariableinstances. The input and output arguments to create afunctionare alsoVariableinstances. AVariableis like a strongly-typed variable in some other languages; eachVariablecontains a reference to aTypeinstance that defines the kind of value theVariablecan take in a computation.A
Variableis a container for four important attributes:typeaTypeinstance defining the kind of value thisVariablecan have,ownereitherNone(for graph roots) or theApplyinstance of whichselfis an output,indexthe integer such thatowner.outputs[index] is this_variable(ignored ifownerisNone),namea string to use in pretty-printing and debugging.
There are a few kinds of
Variables to be aware of: AVariablewhich is the output of a symbolic computation has a reference to theApplyinstance to which it belongs (property: owner) and the position of itself in the owner’s output list (property: index).Variable(this base type) is typically the output of a symbolic computation.Constant: a subclass which adds a default and un-replaceablevalue, and requires that owner is None.TensorVariablesubclass ofVariablethat represents anumpy.ndarrayobject.
TensorSharedVariable: a shared version ofTensorVariable.SparseVariable: a subclass ofVariablethat represents ascipy.sparse.{csc,csr}_matrixobject.RandomVariable.
A
Variablewhich is the output of a symbolic computation will have an owner not equal to None.Using a
Variables’ owner field and anApplynode’s inputs fields, one can navigate a graph from an output all the way to the inputs. The opposite direction is possible with aFunctionGraphand itsFunctionGraph.clientsdict, which mapsVariables to a list of their clients.- Parameters:
type (a Type instance) – The type governs the kind of data that can be associated with this variable.
owner (None or Apply instance) – The
Applyinstance which computes the value for this variable.index (None or int) – The position of this
Variablein owner.outputs.name (None or str) – A string for pretty-printing and debugging.
Examples
import pytensor import pytensor.tensor as pt a = pt.constant(1.5) # declare a symbolic constant b = pt.fscalar() # declare a symbolic floating-point scalar c = a + b # create a simple expression f = pytensor.function( [b], [c] ) # this works because a has a value associated with it already assert 4.0 == f(2.5) # bind 2.5 to an internal copy of b and evaluate an internal c pytensor.function( [a], [c] ) # compilation error because b (required by c) is undefined pytensor.function( [a, b], [c] ) # compilation error because a is constant, it can't be an input
The python variables
a, b, call refer to instances of typeVariable. TheVariablereferred to byais also an instance ofConstant.- clone(**kwargs)[source]#
Return a new, un-owned
Variablelikeself.- Parameters:
**kwargs (dict) – Optional “name” keyword argument for the copied instance. Same as
self.nameif value not provided.- Returns:
A new
Variableinstance with no owner or index.- Return type:
Variable instance
Notes
Tags and names are copied to the returned instance.
- eval(inputs_to_values=None, **kwargs)[source]#
Evaluate the
Variablegiven a set of values for its inputs.- Parameters:
inputs_to_values – A dictionary mapping PyTensor
Variables or names to values. Not needed if variable has no required inputs.kwargs – Optional keyword arguments to pass to the underlying
pytensor.function
Examples
>>> import numpy as np >>> import pytensor.tensor as pt >>> x = pt.dscalar("x") >>> y = pt.dscalar("y") >>> z = x + y >>> np.allclose(z.eval({x: 16.3, y: 12.1}), 28.4) True
We passed
eval()a dictionary mapping symbolic PyTensorVariables to the values to substitute for them, and it returned the numerical value of the expression.Notes
eval()will be slow the first time you call it on a variable – it needs to callfunction()to compile the expression behind the scenes. Subsequent calls toeval()on that same variable will be fast, because the variable caches the compiled function.This way of computing has more overhead than a normal PyTensor function, so don’t use it too much in real scripts.
- get_parents()[source]#
Return a list of the parents of this node. Should return a copy–i.e., modifying the return value should not modify the graph structure.
- pytensor.graph.basic.ancestors(graphs, blockers=None)[source]#
Return the variables that contribute to those in given graphs (inclusive).
- Parameters:
- Yields:
Variables – All input nodes, in the order found by a left-recursive depth-first search started at the nodes ingraphs.
- pytensor.graph.basic.apply_depends_on(apply, depends_on)[source]#
Determine if any
depends_onis in the graph given byapply.
- pytensor.graph.basic.applys_between(ins, outs)[source]#
Extract the
Applys contained within the sub-graph between given input and output variables.- Parameters:
- Yields:
- pytensor.graph.basic.as_string(inputs, outputs, leaf_formatter=<class 'str'>, node_formatter=<function default_node_formatter>)[source]#
Returns a string representation of the subgraph between
inputsandoutputs.- Parameters:
- Returns:
Returns a string representation of the subgraph between
inputsandoutputs. If the same node is used by several other nodes, the first occurrence will be marked as*n -> descriptionand all subsequent occurrences will be marked as*n, wherenis an id number (ids are attributed in an unspecified order and only exist for viewing convenience).- Return type:
list of str
- pytensor.graph.basic.clone(inputs, outputs, copy_inputs=True, copy_orphans=None, clone_inner_graphs=False)[source]#
Copies the sub-graph contained between inputs and outputs.
- Parameters:
inputs – Input
Variables.outputs – Output
Variables.copy_inputs – If
True, the inputs will be copied (defaults toTrue).copy_orphans – When
None, use thecopy_inputsvalue. WhenTrue, new orphans nodes are created. WhenFalse, original orphans nodes are reused in the new graph.clone_inner_graphs (bool) – If
True, cloneHasInnerGraphOps and their inner-graphs.
- Return type:
The inputs and outputs of that copy.
Notes
A constant, if in the
inputslist is not an orphan. So it will be copied conditional on thecopy_inputsparameter; otherwise, it will be copied conditional on thecopy_orphansparameter.
- pytensor.graph.basic.clone_get_equiv(inputs, outputs, copy_inputs=True, copy_orphans=True, memo=None, clone_inner_graphs=False, **kwargs)[source]#
Clone the graph between
inputsandoutputsand return a map of the cloned objects.This function works by recursively cloning inputs and rebuilding a directed graph from the inputs up.
If
memoalready contains entries for some of the objects in the graph, those objects are replaced with their values inmemoand not unnecessarily cloned.- Parameters:
inputs – Inputs of the graph to be cloned.
outputs – Outputs of the graph to be cloned.
copy_inputs –
Truemeans to create the cloned graph from cloned input nodes.Falsemeans to clone a graph that is rooted at the original input nodes.Constants are not cloned.copy_orphans – When
True, inputs with no owners are cloned. WhenFalse, original inputs are reused in the new graph. Cloning is not performed forConstants.memo – Optionally start with a partly-filled dictionary for the return value. If a dictionary is passed, this function will work in-place on that dictionary and return it.
clone_inner_graphs – If
True, cloneHasInnerGraphOps and their inner-graphs.kwargs – Keywords passed to
Apply.clone_with_new_inputs.
- pytensor.graph.basic.clone_node_and_cache(node, clone_d, clone_inner_graphs=False, **kwargs)[source]#
Clone an
Applynode and cache the results inclone_d.This function handles
Opclones that are generated by inner-graph cloning.- Returns:
Noneif all ofnode’s outputs are already inclone_d; otherwise,return the clone of
node.
- pytensor.graph.basic.equal_computations(xs, ys, in_xs=None, in_ys=None, strict_dtype=True)[source]#
Checks if PyTensor graphs represent the same computations.
The two lists
xs,ysshould have the same number of entries. The function checks if for any corresponding pair(x, y)fromzip(xs, ys)xandyrepresent the same computations on the same variables (unless equivalences are provided usingin_xs,in_ys).If
in_xsandin_ysare provided, then when comparing a nodexwith a nodeythey are automatically considered as equal if there is some indexisuch thatx == in_xs[i]andy == in_ys[i](and they both have the same type). Note thatxandycan be in the listxsandys, but also represent subgraphs of a computational graph inxsorys.
- pytensor.graph.basic.explicit_graph_inputs(graph)[source]#
Get the root variables needed as inputs to a function that computes
graph- Parameters:
graph (TensorVariable) – Output
Variableinstances for which to search backward through owners.- Returns:
Generator of root Variables (without owner) needed to compile a function that evaluates
graphs.- Return type:
iterable
Examples
import pytensor import pytensor.tensor as pt from pytensor.graph.basic import explicit_graph_inputs x = pt.vector("x") y = pt.constant(2) z = pt.mul(x * y) inputs = list(explicit_graph_inputs(z)) f = pytensor.function(inputs, z) eval = f([1, 2, 3]) print(eval) # [2. 4. 6.]
- pytensor.graph.basic.general_toposort(outputs, deps, compute_deps_cache=None, deps_cache=None, clients=None)[source]#
Perform a topological sort of all nodes starting from a given node.
- Parameters:
deps (callable) – A Python function that takes a node as input and returns its dependence.
compute_deps_cache (optional) – If provided,
deps_cacheshould also be provided. This is a function likedeps, but that also caches its results in adictpassed asdeps_cache.deps_cache (dict) – A
dictmapping nodes to their children. This is populated bycompute_deps_cache.clients (dict) – If a
dictis passed, it will be filled with a mapping of nodes-to-clients for each node in the subgraph.
Notes
deps(i)should behave like a pure function (no funny business with internal state).deps(i)will be cached by this function (to be fast).The order of the return value list is determined by the order of nodes returned by the
depsfunction.The second option removes a Python function call, and allows for more specialized code, so it can be faster.
- pytensor.graph.basic.get_var_by_name(graphs, target_var_id, ids='CHAR')[source]#
Get variables in a graph using their names.
- Parameters:
graphs – The graph, or graphs, to search.
target_var_id – The name to match against either
Variable.nameorVariable.auto_name.
- Return type:
A
tuplecontaining all theVariables that matchtarget_var_id.
- pytensor.graph.basic.graph_inputs(graphs, blockers=None)[source]#
Return the inputs required to compute the given Variables.
- Parameters:
- Yields:
Input nodes with no owner, in the order found by a left-recursive
depth-first search started at the nodes in
graphs.
- pytensor.graph.basic.io_connection_pattern(inputs, outputs)[source]#
Return the connection pattern of a subgraph defined by given inputs and outputs.
- pytensor.graph.basic.io_toposort(inputs, outputs, orderings=None, clients=None)[source]#
Perform topological sort from input and output nodes.
- Parameters:
inputs (list or tuple of Variable instances) – Graph inputs.
outputs (list or tuple of Apply instances) – Graph outputs.
orderings (dict) – Keys are
Applyinstances, values are lists ofApplyinstances.clients (dict) – If provided, it will be filled with mappings of nodes-to-clients for each node in the subgraph that is sorted.
- pytensor.graph.basic.op_as_string(i, op, leaf_formatter=<class 'str'>, node_formatter=<function default_node_formatter>)[source]#
Return a function that returns a string representation of the subgraph between
iandop.inputs
- pytensor.graph.basic.orphans_between(ins, outs)[source]#
Extract the
Variables not within the sub-graph between input and output nodes.- Parameters:
- Yields:
Variable – The
Variables upon which one or moreVariables inoutsdepend, but are neither ininsnor in the sub-graph that lies between them.
Examples
>>> from pytensor.graph.basic import orphans_between >>> from pytensor.tensor import scalars >>> x, y = scalars("xy") >>> list(orphans_between([x], [(x + y)])) [y]
- pytensor.graph.basic.replace_nominals_with_dummies(inputs, outputs)[source]#
Replace nominal inputs with dummy variables.
When constructing a new graph with nominal inputs from an existing graph, pre-existing nominal inputs need to be replaced with dummy variables beforehand; otherwise, sequential ID ordering (i.e. when nominals are IDed based on the ordered inputs to which they correspond) of the nominals could be broken, and/or circular replacements could manifest.
FYI: This function assumes that all the nominal variables in the subgraphs between
inputsandoutputsare present ininputs.
- pytensor.graph.basic.truncated_graph_inputs(outputs, ancestors_to_include=None)[source]#
Get the truncate graph inputs.
Unlike
graph_inputs()this function will return the closest variables to outputs that do not depend onancestors_to_include. So given all the returned variables provided there is no missing variable to compute the output and all variables are independent from each other.- Parameters:
- Returns:
Variables required to compute
outputs- Return type:
List[Variable]
Examples
The returned variables marked in (parenthesis), ancestors variables are
c, output variables areoNo ancestors to include
n - n - (o)
One ancestors to include
n - (c) - o
Two ancestors to include where on depends on another, both returned
(c) - (c) - o
Additional variables are present
(c) - n - o n - (n) -'
Disconnected ancestors to include not returned
(c) - n - o c
Disconnected output is present and returned
(c) - (c) - o (o)
ancestors to include that include itself adds itself
n - (c) - (o/c)
- pytensor.graph.basic.variable_depends_on(variable, depends_on)[source]#
Determine if any
depends_onis in the graph given byvariable. :param variable: Node to check :type variable: Variable :param depends_on: Nodes to check dependency on :type depends_on: Collection[Variable]- Return type:
bool
- pytensor.graph.basic.vars_between(ins, outs)[source]#
Extract the
Variables within the sub-graph between input and output nodes.
- pytensor.graph.basic.view_roots(node)[source]#
Return the leaves from a search through consecutive view-maps.
- pytensor.graph.basic.walk(nodes, expand, bfs=True, return_children=False, hash_fn=<built-in function id>)[source]#
Walk through a graph, either breadth- or depth-first.
- Parameters:
nodes – The nodes from which to start walking.
expand – A callable that is applied to each node in
nodes, the results of which are either new nodes to visit orNone.bfs – If
True, breath first search is used; otherwise, depth first search.return_children – If
True, each output node will be accompanied by the output ofexpand(i.e. the corresponding child nodes).hash_fn – The function used to produce hashes of the elements in
nodes. The default isid.
Notes
A node will appear at most once in the return value, even if it appears multiple times in the
nodesparameter.