Scott White
08/29/2022, 1:34 PMprefect<2.0
and the functional API?
I will share the pseudo-code and syntax in a reply.import prefect
from prefect.tasks.prefect import create_flow_run
def get_update_date():
return '2022-01-01'
def trigger_flow(**kwargs):
create_flow_run.run(
flow_name='flow-2'
project_name='test',
parameters={'update_date': kwargs.get('update_date')}
)
get_update_date = prefect.task(get_update_date)
trigger_flow = prefect.task(trigger_flow)
with prefect.Flow('flow-1') as flow:
update_date = get_update_date()
trigger_flow(update_date=update_date)
import prefect
update_date = prefect.Parameter('update_date', default=None)
def print_date(update_date):
prefect.logger(f'{update_date}')
print_date = prefect.task(print_date)
with prefect.Flow('flow-2') as flow:
print_date()
None
when it is triggered by flow-1
but if I trigger flow-2
manually with a hard-coded update_date
it will print just fineJeff Hale
08/29/2022, 3:51 PM