import asyncio
from prefect.client.orchestration import get_client
from prefect.client.schemas.filters import DeploymentFilter, DeploymentFilterId
from uuid import UUID


async def read_flows_for_deployment(deployment_id: UUID):
    async with get_client() as client:
        flow_runs = await client.read_flow_runs(
            deployment_filter=DeploymentFilter(
                id=DeploymentFilterId(any_=[deployment_id])
            )
        )
        for r in flow_runs:
            print(r.id)


if __name__ == '__main__':
    asyncio.run(read_flows_for_deployment(UUID("d6f41eb0-bbef-4d9e-b84d-aad77deb396b")))