Keep worker publish errors structured
Build and publish rule engine / release (push) Failing after 10s
Build and publish rule engine / release (push) Failing after 10s
This commit is contained in:
@@ -83,7 +83,7 @@ async fn respond(client: Client, reply: Subject, payload: Vec<u8>) {
|
|||||||
if let Err(error) = client.publish(reply, payload.into()).await {
|
if let Err(error) = client.publish(reply, payload.into()).await {
|
||||||
eprintln!(
|
eprintln!(
|
||||||
"{{\"level\":\"error\",\"event\":\"rule.reply_publish_failed\",\"error_category\":\"nats_publish\",\"detail\":{:?}}}",
|
"{{\"level\":\"error\",\"event\":\"rule.reply_publish_failed\",\"error_category\":\"nats_publish\",\"detail\":{:?}}}",
|
||||||
error.to_string()
|
error
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user