feat(kitchen-sink): add churnDb actor and seed driver for compaction read-hotshard repro

engine/packages/gasoline/src/db/kv/mod.rs

@@ -2604,7 +2604,6 @@ impl Database for DatabaseKv {
 		signal_name: &str,
 		body: &serde_json::value::RawValue,
 	) -> WorkflowResult<()> {
-		let started_at = Instant::now();
 		self.pools
 			.udb()
 			.map_err(WorkflowError::PoolsGeneric)?

engine/packages/universaldb/src/driver/postgres/database.rs

@@ -35,7 +35,7 @@ const GC_INTERVAL: Duration = Duration::from_secs(30);
 /// Failover dedup rows older than this are garbage collected. Must be well beyond the longest a
 /// follower could spend resending a commit across a leader failover, so a dedup record is never
 /// deleted while a resend that needs it could still arrive.
-const DEDUP_ROW_MAX_AGE_SECS: i64 = 60;
+const DEDUP_ROW_MAX_AGE_SECS: i64 = 120;
 
 #[derive(Clone, Debug)]
 pub struct PostgresConfig {

engine/packages/util/src/serde.rs

@@ -73,7 +73,7 @@ macro_rules! json_from_slice {
 		$crate::metrics::DESERIALIZE_SIZE
 			.with_label_values(&["json", $crate::location!().to_string().as_str()])
 			.observe(__bind.len() as f64);
-		$crate::observe!(serde_json::from_slice($value))
+		$crate::observe!(serde_json::from_slice(__bind))
 	}};
 }
 pub use json_from_slice;
@@ -101,7 +101,7 @@ macro_rules! bare_from_slice {
 		$crate::metrics::DESERIALIZE_SIZE
 			.with_label_values(&["bare", $crate::location!().to_string().as_str()])
 			.observe(__bind.len() as f64);
-		$crate::observe!(serde_bare::from_slice($value))
+		$crate::observe!(serde_bare::from_slice(__bind))
 	}};
 }
 pub use bare_from_slice;