Update worker.rs

PostHog · Aug 6, 2024 · 804494d · 804494d
1 parent d8ce6c4
commit 804494d
Showing 1 changed file with 8 additions and 12 deletions.
diff --git a/rust/hook-worker/src/worker.rs b/rust/hook-worker/src/worker.rs
@@ -266,18 +266,14 @@ async fn process_batch<'a>(
 
     let results = join_all(futures).await;
 
-    if hog_mode {
-        if (push_hoghook_results_to_kafka(
-            results,
-            metadata_vec,
-            kafka_producer,
-            cdp_function_callbacks_topic,
-        )
-        .await)
-            .is_err()
-        {
-            return;
-        }
+    if hog_mode && push_hoghook_results_to_kafka(
+        results,
+        metadata_vec,
+        kafka_producer,
+        cdp_function_callbacks_topic,
+    ).await.is_err()
+    {
+        return;
     }
 
     let _ = batch.commit().await.map_err(|e| {