big-easter-12386
11/20/2023, 4:27 PMbig-easter-12386
11/20/2023, 4:44 PMdef get_node_dependencies(workflow) -> dict[str, list[str]]:
links = {}
for node in workflow.nodes:
links[node.flyte_entity.name] = [n.flyte_entity.name for n in node.upstream_nodes]
return links
freezing-airport-6809
big-easter-12386
11/20/2023, 6:09 PMA
.
However, some of those tasks have upstream dependencies, which can also be requested independently.
If a user requests a task which has upstream dependencies, but they do not explicitly request those dependencies in A
, we'd like to automatically add them to A
so that the workflow can complete successfully.
While we can manually describe the relationships between these tasks, since they're already part of a workflow which already converts these tasks into a DAG, we were wondering if it was possible to leverage that DAG directly 🤔