feat(propdefs): try not to sleep in the hot loop, eh (#24658)

PostHog · Aug 28, 2024 · 934813d · 934813d
1 parent 3800952
commit 934813d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/rust/property-defs-rs/src/main.rs b/rust/property-defs-rs/src/main.rs
@@ -97,10 +97,10 @@ async fn spawn_producer_loop(
                     sent.insert(update.clone());
                     match channel.try_send(update) {
                         Ok(_) => {}
-                        Err(TrySendError::Full(_)) => {
+                        Err(TrySendError::Full(update)) => {
                             warn!("Worker blocked");
                             metrics::counter!(WORKER_BLOCKED).increment(1);
-                            tokio::time::sleep(Duration::from_secs(1)).await;
+                            channel.send(update).await.unwrap();
                         }
                         Err(e) => {
                             warn!("Coordinator send failed: {:?}", e);