https://dagster.io/ logo
Title
a

Andrea Giardini

01/03/2022, 10:33 AM
Hello everyone 👋 There is one thing in dagster that is still not 100% clear to me... I am using ins/outs to define my ops inputs and outputs. When i try to do the same for graphs/jobs though, this does not seem to work as I would expect. This graph for example:
@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?
Answer to myself 🙂
GraphIn
is the way to go (even though the documentation is a bit lacking)
🙏 1