Matias Godoy
04/27/2020, 3:42 PMKyle Moon-Wright
04/27/2020, 4:11 PMtasks.cloud.flowruntask
which is documented here.Jacques
04/27/2020, 7:15 PMJeremiah
04/27/2020, 7:49 PMMatias Godoy
04/28/2020, 7:10 AMalvin goh
04/28/2020, 7:35 AMJacques
04/28/2020, 9:01 AMself.page_token = XXX
, and in the monitoring loop I do something like try: task.page_token
and if it doesn't except I pass that value into an updated parameters and submit a new flow.run() thread future.alvin goh
04/28/2020, 9:03 AMJacques
04/28/2020, 9:09 AMMatias Godoy
04/28/2020, 9:38 AMfrom prefect.tasks.cloud.flow_run import FlowRunTask
kickoff_task = FlowRunTask(project_name='my_project', flow_name='my_flow', parameters=params)
kickoff_task.run()
FlowRunTask
Client
:
from prefect import Client
client = Client()
client.create_flow_run(flow_id='my-uuid', parameters=params, run_name='A nice name')