bolto6
08/07/2020, 12:32 PMb_flow
from a_flow
and dir parameter?
Flow A:
python
@task
def any_work(a: str) -> str:
return f'/tmp/{a}'
with Flow('a_flow') as flow:
name = Parameter('name', default='all')
result = any_work(name)
Flow B:
python
@task
def any_work(a: str, b: str) -> str:
return f'{a}/{b}'
with Flow('b_flow') as flow:
home = Parameter('home', required=True)
dir = Parameter('dir', default='any')
result = any_work(home, dir)
Flow C:
python
a_flow = FlowRunTask(flow_name='a_flow', wait=True)
b_flow = FlowRunTask(flow_name='b_flow', wait=True)
with Flow('c_flow') as flow:
name = Parameter('name', default='all')
dir = Parameter('dir', default='any')
a_flow_state = a_flow(parameters={'name': name})
# this error code, but how i can add parameters in `b_flow` from `a_flow` and dir parameter?
result = b_flow(
upstream_tasks=[a_flow_state],
parameters={
'home': a_flow_state.result,
'dir': dir,
},
)
nicholas
08/07/2020, 2:19 PM@task
def any_work(a: str) -> str:
return f'/tmp/{a}'
@task
def any_work(a: str, b: str) -> str:
return f'{a}/{b}'
with Flow('a_flow') as flow:
name = Parameter('name', default='all')
result = any_work(name)
FlowRunTask(flow_name="b_flow", parameters={'home': result})
etc.