Problem
Example code that returns the error from the title:
@task
def add_one(val):
return val + 1
with Flow("Add One") as flow:
p = Parameter("param")
first = add_one(p)
second = add_one(p, upstream_tasks=[first])
Solution
second = add_one(p, upstream_tasks=[first]) # pylint: disable=unexpected-keyword-arg