Vitaly Shulgin
01/20/2021, 9:26 PMwith Flow("test") as flow:
job_type = "play_serach_target"
flow.add_edge(JobsExtract(play_type=job_type), JobsLoad(job_type))
Jim Crist-Harif
01/20/2021, 9:28 PMkey
kwarg to add_edge
, which is the name of the parameter that edge maps to in the downstream task run
method.Vitaly Shulgin
01/21/2021, 6:22 AM