<@ULVA73B9P> show an example of using conditional ...
# ask-marvins
Shaoyi Zhang
07/09/2024, 8:59 PM@Marvin show an example of using conditional tasks to skip flow runs if there is already a flow run for a specific deployment running.
m
Marvin
07/09/2024, 8:59 PMIt seems I encountered an error with the document search, but I do have a basic task example for you. For conditional tasks and skipping a flow run, here's a cohesive example of how you might achieve that by querying the Prefect API to check if a flow run is already in progress:
Copy code
python
from prefect import flow, task, get_client
from prefect.states import Cancelled
@task
async def check_running_flows(deployment_id: str, flow_name: str) -> bool:
async with get_client() as client:
running_flows = await client.read_flow_runs(
deployment_id=deployment_id,
state_names=["Running"],
flow_name=flow_name
)
return len(running_flows) > 0
@task
def do_something():
return "Task executed!"
@flow
async def conditional_flow(deployment_id: str, flow_name: str):
running = await check_running_flows(deployment_id, flow_name)
if running:
print("Flow is already running, skipping execution.")
return Cancelled()
result = do_something()
print(result)
if __name__ == "__main__":
deployment_id = "your_deployment_id"
flow_name = "conditional_flow"
conditional_flow(deployment_id, flow_name)check_running_flowsdo_somethingconditional_flowcheck_running_flowsCancelleddo_something6 Views