Manuel Aristarán
03/06/2020, 6:54 PM{<Parameter: tap_catalog>, <Parameter: tap_config>}
josh
03/06/2020, 7:00 PMIn [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>}
target_config
isn’t being picked up on run_cassandra_target
🤔 what happens when you run the flow?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>}
Manuel Aristarán
03/06/2020, 7:16 PMrun_cassandra_target
with @task
josh
03/06/2020, 7:18 PM