(self, subs: dict, key: KeyType | None = None)
| 355 | return TaskRef, (self.key,) |
| 356 | |
| 357 | def substitute(self, subs: dict, key: KeyType | None = None) -> TaskRef | GraphNode: |
| 358 | if self.key in subs: |
| 359 | val = subs[self.key] |
| 360 | if isinstance(val, GraphNode): |
| 361 | return val.substitute({}, key=self.key) |
| 362 | elif isinstance(val, TaskRef): |
| 363 | return val |
| 364 | else: |
| 365 | return TaskRef(val) |
| 366 | return self |
| 367 | |
| 368 | |
| 369 | def _is_dask_future(obj: object) -> bool: |
nothing calls this directly
no test coverage detected