Node
Node(
processor: Any ,
plan: collections.abc.Mapping[str, Any] =
contract: dascore.lazy.contract.ChunkContract | None[ChunkContract, None] = None,
shape: tuple[tuple[int, …], None] = None,
dtype: numpy.dtype | None[dtype, None] = None,
data_id: str | None[str, None] = None,
)-> None
One pending operation, and what it made once settled.
Parameters
| Parameter | Description |
|---|---|
| processor |
The PatchProcessorwhose kernel computes the step. |
| plan | The arguments its kernel takes beyond the data. |
| contract |
The chunk contract the step was chained under, so what was promised is recorded with the step rather than asked for again. |
| shape, dtype | The shape and dtype the step’s metadata states; None while pending. |
| data_id |
The data_id of the patch this step produced; None while pending.
|
Methods
| Name | Description |
|---|---|
| made |
Return the shape, dtype and data_id of what the step made.
|
| settled | Return this step with the output it states and the id it was given. |