try using async backtrace

Author: evanh

Cargo.lock

@@ -10,6 +10,7 @@ debug = 1
 
 [dependencies]
 anyhow = "1.0.92"
+async-backtrace = "0.2.7"
 base64 = "0.21.0"
 bytes = "1.10.0"
 chrono = { version = "0.4.26" }

Cargo.toml

@@ -1,14 +1,14 @@
-use std::{
-    sync::Arc,
-    time::{Duration, Instant},
-};
-
 use crate::{
     config::Config,
     store::inflight_activation::{InflightActivation, InflightActivationStatus},
     store::inflight_redis_activation::RedisActivationStore,
 };
+use async_backtrace::framed;
 use chrono::Utc;
+use std::{
+    sync::Arc,
+    time::{Duration, Instant},
+};
 use tokio::time::sleep;
 use tracing::{debug, error, instrument};
 
@@ -68,7 +68,7 @@ impl Reducer for InflightActivationWriter {
         Ok(())
     }
 
-    #[instrument(skip_all)]
+    #[framed]
     async fn flush(&mut self) -> Result<Option<Self::Output>, anyhow::Error> {
         let Some(ref batch) = self.batch else {
             return Ok(None);