AyushB
01/26/2025, 6:32 PMSamuel Hinton
01/27/2025, 12:41 AMfrom prefect import get_client
from prefect.client.schemas.filters import (
LogFilter,
LogFilterFlowRunId,
)
async with get_client() as client:
log_filter = LogFilter(flow_run_id=LogFilterFlowRunId(any_=[flow_run_id]))
logs = await client.read_logs(log_filter)