hi all, I'm trying to do a conditional flow, but as you can see i get matches, check if the matches are valid, and then only want to continue if they are. Because i am passing matches into those tasks, they run regardless of if the condition is true or not. What am i doing wrong here?

with flow:
    start_date, end_date = Parameter("start-date", default=None), Parameter("end-date", default=None)
    start_date, end_date = set_date_params(start_date, end_date)
    matches = get_completed_matches_by_date_range(start_date, end_date)
    there_are_matches = are_there_any_matches(matches)
    with case(there_are_matches, True):
        some_data = some_task.run(matches)

Why are you calling the

.run

under case?

thats probably misleading, the module is "some_task" and the function is run

Ah I see what you mean. I think you can visualize the DAG to see the upstreams?

yeah thats what was misleading, but maybe the behavior isn't actually what the dag is showing

ah ok