Tobias Schmidt11/18/2019, 9:47 AM
. I want task A to be skippable via a command line argument to the Python script that implements that flow. What's the best way to do this? Can I mark A as skipped, set
A -> B -> C
on B and C (or just B?) to False and then run the flow as usual? Or is there a more idiomatic way of doing this?
emre11/18/2019, 9:57 AM
I’m personally satisfied with the result, as it keeps flow clean depending on my config, but this can get wonky pretty quick. I’m as much interested about hearing how people approach this problem of flow customization.
with Flow('name') as flow: upstream_tasks_b =  if not skip_a: a_result = A()() upstream_tasks_b.append(a_result) b_result = b()( upstream_tasks=upstream_tasks_b ) c_result = c()(b_result)
inside task A depending on a
passed to it at runtime. A would mark itself as skipped and B or C could respond appropriately (through
, for example)