Flush never completes if too large of item is submitted #308
Description
import os
from posthog import Posthog
POSTHOG_API_KEY = os.environ["POSTHOG_API_KEY"]
posthog = Posthog(POSTHOG_API_KEY, host="https://us.i.posthog.com")
posthog.capture_exception(
Exception("Test Exception"),
properties={
"user_id": "123",
"context": "test"
}
)
posthog.flush()
print("Flushed first exception")
posthog.capture_exception(
Exception("1234567890" * 90000),
properties={
"user_id": "123",
"context": "test"
}
)
posthog.flush() # <----- hangs here
print("Flushed second exception")The consumer code needs to mark self.queue.task_done() when discarding items that are too large.