karteekaddanki
07/14/2020, 3:23 PMJim Crist-Harif
07/14/2020, 3:27 PMMark McDonald
07/14/2020, 3:27 PM@task(name="Trigger downstream flows", trigger=all_successful)
def trigger_downstream_flows():
"""
Make a GraphQL call to trigger downstream flows.
:return: None
"""
c = Client()
c.graphql("""
mutation {
create_flow_run(input: { version_group_id: "1234-abcd-1234-abcd" }) {
id
}
}
""")
Jim Crist-Harif
07/14/2020, 3:28 PMkarteekaddanki
07/14/2020, 3:31 PMJim Crist-Harif
07/14/2020, 3:31 PMFlowRunTask
(https://docs.prefect.io/api/latest/tasks/prefect.html#flowruntask) to kick off a flow run if it needs to run. The caching mechanism can be useful here though, and would be the first thing I'd recommend if it works.karteekaddanki
07/17/2020, 12:42 PMFlowRunTask
expected to update the runs of the child flow in prefect cloud? I'm not seeing it. I'm trying to implement backfill functionality using FlowRunTask
via a generic wrapper task.Jim Crist-Harif
07/17/2020, 1:58 PMFlowRunTask
should kick off a new flow run in prefect cloud. However, depending on your cloud account you might have limits on the number of active flow runs, so you might not see that flow run start for a bit.