Revert "fix: check if future exists before grabbing it (#17562)"

This reverts commit 94a7bc9.
PostHog · Sep 20, 2023 · 4ac08eb · 4ac08eb
1 parent 2f14262
commit 4ac08eb
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/posthog/api/capture.py b/posthog/api/capture.py
@@ -426,8 +426,7 @@ def get_event(request):
         start_time = time.monotonic()
         for future in futures:
             try:
-                if future is not None:
-                    future.get(timeout=settings.KAFKA_PRODUCE_ACK_TIMEOUT_SECONDS - (time.monotonic() - start_time))
+                future.get(timeout=settings.KAFKA_PRODUCE_ACK_TIMEOUT_SECONDS - (time.monotonic() - start_time))
             except KafkaError as exc:
                 # TODO: distinguish between retriable errors and non-retriable
                 # errors, and set Retry-After header accordingly.