Dilip Thiagarajan
01/21/2021, 3:48 PMZanie
prefect.client.Client.write_run_logs
here’s an example from the code
# Send pod failure information to flow run logs
self.client.write_run_logs(
[
dict(
flow_run_id=flow_run_id,
name="k8s-infra",
message="\n".join(pod_status_logs),
level="ERROR",
)
]
)