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

Revert "fix: check if future exists before grabbing it (#17562)" This reverts commit 94a7bc9.
PostHog · Sep 21, 2023 · 39e705c · 39e705c
1 parent 4ed79a6
commit 39e705c
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.