We pass custom execution options to our nodes with the graph.add_node(metadata=…)field provided by the Graph API. We’re also interested in using the Functional API and would like to request the addition of a@task(metadata=….) field for tasks.
Without this fix, we need to pass a dictionary of custom execution options, and look up tasks by name, which looks something like the following:
{
"task-1": {
"option-1": 1,
"option-2": 2,
},
...
}
We’ve already made and tested this change on our fork and have validated it in our codebase. Let me know if I have permission to open a PR. Thank you!