GKaszewski/thoughts
1
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

fix: promote worker event logs from debug to info

Browse Source
This commit is contained in:
Gabriel Kaszewski
2026-05-17 12:02:13 +02:00
parent 2c34eb44e4
commit be0924d463
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
crates/worker/src/main.rs
View File

@@ -43,13 +43,15 @@ async fn main() {
match result { match result {
Ok(envelope) => { Ok(envelope) => {
let event = &envelope.event; let event = &envelope.event;
tracing::debug!(?event, "received event"); let event_type = event_payload::EventPayload::from(event).subject();
tracing::info!(event_type, delivery = envelope.delivery_count, "received event");
let n = infra.handlers.notification.handle(event).await; let n = infra.handlers.notification.handle(event).await;
let f = infra.handlers.federation.handle(event).await; let f = infra.handlers.federation.handle(event).await;
if n.is_ok() && f.is_ok() { if n.is_ok() && f.is_ok() {
(envelope.ack)(); (envelope.ack)();
tracing::info!(event_type, "event handled ok");
} else { } else {
if let Err(e) = &n { if let Err(e) = &n {
tracing::error!("notification handler: {e}"); tracing::error!("notification handler: {e}");

2
crates/worker/src/outbox_relay.rs
View File

@@ -100,7 +100,7 @@ impl OutboxRelay {
.execute(&mut *tx) .execute(&mut *tx)
.await?; .await?;
tx.commit().await?; tx.commit().await?;
tracing::debug!(seq = row.seq, event_type = row.event_type, "outbox: delivered"); tracing::info!(seq = row.seq, event_type = row.event_type, "outbox: delivered");
} }
Err(e) => { Err(e) => {
tracing::warn!(seq = row.seq, "outbox: publish failed (will retry): {e}"); tracing::warn!(seq = row.seq, "outbox: publish failed (will retry): {e}");