BUG: ingest dropped logs while waiting for task_queue to be empty