Andrew Vaccaro
04/17/2020, 10:06 PMupstream_tasks
to the same task being called twice with different arguments. I have something like
A(abcd)
B.set_dependencies(upstream_tasks=[A], keyword_tasks=...)
A(defg)
B.set_dependencies(upstream_tasks=[A], keyword_tasks=...)
where B must run after A, and each gets called with two separate sets of Parameters. If I call B.set_dependencies(upstream_tasks=[A])
twice, will the second B wait on the second A? And is this the idiomatic way to do this?nicholas
04/17/2020, 10:14 PMA
to a variable each time, and then reference that variable like such:
a1 = A(abcd)
B().set_dependencies(upstream_tasks=[a1], keyword_tasks=...)
a2 = A(defg)
B().set_dependencies(upstream_tasks=[a2], keyword_tasks=...)
Andrew Vaccaro
04/17/2020, 10:15 PMnicholas
04/17/2020, 10:16 PMAndrew Vaccaro
04/17/2020, 10:34 PMB.set_dependencies(upstream_tasks=[A], keyword_tasks={'a': 123})
roughlynicholas
04/17/2020, 10:59 PM()
to those B tasks, otherwise it's referencing the same object! I've amended the code above, sorry again!