DJ Erraballi
11/06/2020, 5:54 PMDylan
DJ Erraballi
11/06/2020, 6:05 PMFlowRunTask
for executing this kind of trigger from outside of prefect, i would just use the client right?
client = Client()
flow = client.graphql(query).data.flow
# verify that a flow has been returned
if not flow:
raise ValueError("Flow '{}' not found.".format(flow_name))
# grab the ID for the most recent version
flow_id = flow[0].id
return client.create_flow_run(flow_id=flow_id, parameters=parameters)
Dylan
wait=True
and then the Task will take on the state of the Flow Run it kicked off (Failed
, Success
, etc) and you can take further actions based on that if you’d likeDJ Erraballi
11/06/2020, 7:29 PMDylan
DJ Erraballi
11/09/2020, 5:43 PM