Unanswered
I Have A Pipeline With Tasks A->B->C.
I Want To Be Able To Trigger It Manually, And Skip A Regardless Of It’S Cache Status.
I Want To Pass B Value That Represents A’S Output If Needed.
What’S A Good Way To Achieve This (Can Be Ui-Based, Or Pipeline-Gymnas
Decorators are good 🙂
Something along the lines of
` @PipelineDecorator.pipeline(...)
def pipeline(skip_a=False):
if not skip_a:
a = step_a()
else:
# somehow get a previous A?
# let's call it cached A
a = "replace with real'
step_b(a)
... `Is this the gist?
If it is, this looks like, "how can I control whether A is cached or not", is that correct?
186 Views
0
Answers
2 years ago
one year ago