Im trying to use local dask executor and add task dependency from the previous task like below (Using prefect 1) but running this gives me and error saying

add_json_index() missing 1 required positional argument: 'output'

output = filter_empty_responses(data)

    # Parsing Jsons
    indexed_output = add_json_index(output, upstream_tasks=[filter_empty_responses])

can you share a full minimal reproducible example?