You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
class InputParams(BaseModel):
name: str
def foo(params: InputParams):
print(params.name)
def all_printed():
print('all printed, yay!')
names = ['bar', 'foo', 'foobar', 'barfoo']
register_pipeline(
id="pipeline",
tasks=[foo],
params=InputParams,
triggers=[
Trigger(
id=f'foo_{name}', name=f'foo_{name}', schedule=IntervalTrigger(days=1),
params={'name': name}
) for name in names
],
)
I would ideally like to run a pipeline that goes like: foo('bar'), foo('foo'), foo('foobar'), foo('barfoo'), all_printed(). Is this possible, or should I create another pipeline, and "hope" that the previous one finished?
The text was updated successfully, but these errors were encountered:
At the moment is not possible, but it's something I'd like to support, so in the future you can create a foo pipeline with a matrix trigger #14 where you specify the list of arguments and then trigger the all_printed pipeline at the end of the foo pipeline #146
i have a pipeline that looks like the following:
I would ideally like to run a pipeline that goes like: foo('bar'), foo('foo'), foo('foobar'), foo('barfoo'), all_printed(). Is this possible, or should I create another pipeline, and "hope" that the previous one finished?
The text was updated successfully, but these errors were encountered: