ProvenanceNode
ProvenanceNode(
task: dascore.workflow.task.Task | None[Task, None] = None,
parents: tuple[ProvenanceNode, …] = (),
input_pairs: tuple[tuple[str, str], …] = (),
patch_id: str = ““,
processing_id: str =”“,
source: dascore.workflow.provenance.SourceInfo | None[SourceInfo, None] = None,
backend: str | None[str, None] = None,
created_at: datetime =
)-> None
One step of what was done to some data.
A node holds the task which ran, the nodes which produced its inputs, and the ids the step produced. Nodes are never edited: a further step makes another node which points back at this one, so a graph is shared by everything downstream of it rather than copied.
Methods
| Name | Description |
|---|---|
| describe | Return a readable listing of what was done, oldest first. |
| from_json | Return the graph some JSON text holds. |
| new | Create new instance with some attributed updated. |
| sources | Return where the data behind this node was read from. |
| steps | Return the nodes which did something, oldest first. |
| to_json | Return the graph behind this node as JSON text. |
| to_pipe | Return a pipe which would do again what this node records. |
| walk | Yield every node behind this one and then this one, each once. |