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.Scott White
08/29/2022, 1:45 PMimport 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)Scott White
08/29/2022, 1:48 PMimport 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()Scott White
08/29/2022, 1:48 PMNone 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