Hi - I'm having an issue with setting a parameter according to the documentation found here: https://docs.prefect.io/core/concepts/parameters.html My flow looks like this:

with Flow('Kafka Data Quality Test') as flow:
    full_run = Parameter('full_run', default=False)

flow.run(parameters=dict(full_run=True))

and I keep getting this error:

Traceback (most recent call last):
  File "src/app.py", line 243, in <module>
    flow.run(parameters=dict(full_run=True))
  File "/Users/apost/ccde/ccde-kafka-data-quality/venv/lib/python3.7/site-packages/prefect/core/flow.py", line 991, in run
    fmt_params
ValueError: Flow.run received the following unexpected parameters: full_run

Has anyone seen this before?

Hey @Alex Post instantiating the

Parameter

does not actually add it to the flow and you will need to either call

flow.add_task

for that parameter or use it in another task!

got it, thanks!

Take a look at the section on parameters in this doc if you want more info 🙂 https://docs.prefect.io/core/tutorials/task-guide.html#adding-tasks-to-flows

@josh when I try this from that link:

from prefect import Parameter

with Flow("add-example-v3") as f:
    # we will instantiate these Parameters here
    # but note that does NOT add them to the flow yet
    x = Parameter("x", default=1)
    y = Parameter("y", default=2)

    result = add_task(x=x, y=y) # <-- the moment at which x, y are added to the Flow

print(f.tasks) # {<Task: add_task>, <Parameter: y>, <Parameter: x>}

add_task in f.tasks # False
result in f.tasks # True

x in f.tasks # True
y in f.tasks # True

Do

add_task(full_run)

,

full_run

isn’t a kwarg of

add_task

as it accepts any task to add to the Flow

ah, ok, that did it. thanks!

That doc needs to be updated! Thanks for finding this

oh I see