Andrea Giardini
01/03/2022, 10:33 AM@graph(
ins={
"gcs_list": In(List[str]),
}
)
def airbus_tristereo_orthorectification_pansharpening(gcs_lists):
generate_subtasks(gcs_lists).map(orthorectify_pansharpen_tristereo_op)
I would expect dagit to ask me for a parameter gcs_list before starting the job but indeed that's not the case.
Is it possible to define job/graph-wide inputs and outputs?GraphIn
is the way to go (even though the documentation is a bit lacking)