Blake List
09/07/2021, 2:09 AMa, b, and c started within parent flow p using startflowrun, how can I trigger (or not trigger) flow c , given the states of flows (startflowrun tasks) a and b ? Within flows a and b , there is a task to skip downstream tasks (raising a SKIP signal) based on a condition. Thanks in advance.Kevin Kho
StartFlowRun returns a key that you can pass to a query. This might be a starting point.
client = Client()
response = client.graphql(
f"""
query {{
flow_run_by_pk ( id: "{flow_run_id}" ),
{{
id,
flow {{
id,
name,
}}
state,
task_runs {{
id,
state,
state_message,
task {{
id,
name,
slug,
type
}}
}}
}}
}}"""
)
returnBring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by