Channels
#prefect-community
Title
# prefect-community
m
Manuel Aristarán
03/06/2020, 6:54 PMthis is the result of `print(f.parameters())`:
Copy code
{<Parameter: tap_catalog>, <Parameter: tap_config>}j
josh
03/06/2020, 7:00 PMNot entirely sure what’s going on here at first glance but I can say flows definitely accept an arbitrary number of parameters 🙂
Copy code
In [18]: @task
...: def vals(x1, x2, x3):
...: print(x1, x2, x3)
...:
In [19]: with Flow('test') as flow:
...: p1 = Parameter('p1')
...: p2 = Parameter('p2')
...: p3 = Parameter('p3')
...: vals(p1, p2, p3)
...:
In [20]: flow.parameters()
Out[20]: {<Parameter: p1>, <Parameter: p2>, <Parameter: p3>}It’s almost like
target_configrun_cassandra_targetHere’s a setup similar to yours and I am getting the proper amount of parameters on the flow:
Copy code
In [23]: @task
...: def take_two(x, y):
...: return x + y
...:
In [24]: @task
...: def take_res_and_param(param, res):
...: print(param + res)
...:
In [25]: with Flow('test') as flow:
...: p1 = Parameter('p1')
...: p2 = Parameter('p2')
...: p3 = Parameter('p3')
...: res = take_two(p1, p2)
...: take_res_and_param(p3, res)
...:
...:
In [26]: flow.parameters()
Out[26]: {<Parameter: p1>, <Parameter: p2>, <Parameter: p3>}m
Manuel Aristarán
03/06/2020, 7:16 PMARGH 😬 Forgot to decorate
run_cassandra_target@task(it’s my first stab at a Flow, sorry ab that)
j
josh
03/06/2020, 7:18 PMNo problem! Glad you got it sorted out