fix: Bump timeout for migrate kafka tests

PostHog · Nov 1, 2023 · 50add8f · 50add8f
1 parent 0813b0a
commit 50add8f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/posthog/management/commands/test/test_migrate_kafka_data.py b/posthog/management/commands/test/test_migrate_kafka_data.py
@@ -343,7 +343,7 @@ def _wait_for_message(topic: str, key: str):
     )
 
     try:
-        messages_by_topic = new_kafka_consumer.poll(timeout_ms=1000)
+        messages_by_topic = new_kafka_consumer.poll(timeout_ms=10000)
 
         if not messages_by_topic:
             return