From 751ac447ce6aa1206e69897ca9fe8afd8728c465 Mon Sep 17 00:00:00 2001
From: Oliver Browne <oliver@posthog.com>
Date: Tue, 6 Aug 2024 19:03:46 +0300
Subject: [PATCH] fix: need to release a new version, didn't like how this was
 worded (#24223)

---
 rust/hook-worker/src/worker.rs | 18 ++++++------------
 1 file changed, 6 insertions(+), 12 deletions(-)

diff --git a/rust/hook-worker/src/worker.rs b/rust/hook-worker/src/worker.rs
index dd4bb8229fa43..cfa7523883c69 100644
--- a/rust/hook-worker/src/worker.rs
+++ b/rust/hook-worker/src/worker.rs
@@ -266,23 +266,17 @@ async fn process_batch<'a>(
 
     let results = join_all(futures).await;
 
-    if hog_mode {
-        // System relevant - this means that our requests are at-least once, since if we do the
-        // request, it succeeds, and then our kafka is down, we'll do the request again. This was
-        // already true on batch commit, but now it's true on kafka send as well. We could add a
-        // "returned" state to the state machine that indicates "we made the request but haven't
-        // pushed it to kafka yet", but we need to decide that's something we care about first.
-        if (push_hoghook_results_to_kafka(
+    if hog_mode
+        && push_hoghook_results_to_kafka(
             results,
             metadata_vec,
             kafka_producer,
             cdp_function_callbacks_topic,
         )
-        .await)
-            .is_err()
-        {
-            return;
-        }
+        .await
+        .is_err()
+    {
+        return;
     }
 
     let _ = batch.commit().await.map_err(|e| {