consumer.py: mark task_done for discarded items

[masenf]

Fixes #308

[greptile-apps]

Greptile Summary

This PR fixes a critical queue synchronization bug in the Consumer class's next() method. The issue occurred when items exceeded the 900KiB size limit (MAX_MSG_SIZE) - these oversized items were being dropped from the queue without calling queue.task_done(), which left the queue's internal task counter unbalanced.

The Consumer class uses Python's Queue with task tracking, where every item retrieved with queue.get() must have a corresponding queue.task_done() call. When the consumer encountered an oversized item, it would log an error and continue processing, but never marked that task as complete. This caused the queue.join() method (used by the flush() operation) to hang indefinitely, waiting for tasks that had already been discarded.

The fix adds a single line queue.task_done() after the error logging for oversized items. This ensures that even discarded items are properly acknowledged in the queue's task counting system, allowing the flush operation to complete normally. The change maintains the existing behavior of dropping oversized items while fixing the synchronization issue that could cause the application to hang.

Confidence score: 5/5

• This PR is extremely safe to merge with virtually no risk of causing issues
• Score reflects a minimal, well-targeted fix for a clearly identified synchronization bug with no side effects
• No files require special attention as this is a single-line fix in a well-understood code path

_{1 file reviewed, no comments}

_{Edit Code Review Bot Settings | Greptile}