Mitchell Bregman
09/06/2023, 7:49 PMres = await client.read_flow_runs(deployment_filter={"DeploymentID": "2d73c29e-5865-44d4-8f4e-4e3d9dc0442c"})
results in:
AttributeError: 'dict' object has no attribute 'dict'
DeploymentFilter
object?Jake Kaplan
09/06/2023, 7:56 PMimport 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")))
Mitchell Bregman
09/06/2023, 8:14 PMawait client.set_flow_run_state(r.id, Cancelled(), True)
Jake Kaplan
09/06/2023, 8:19 PM