Eventlet affirme une exception sur la file d'attente.put

Question

Je reçois des exceptions bizarres de temps en temps lorsque j'essaie de mettre en file d'attente un élément.

for message in kafka_consumer: 
    queue_in.put(message.value) 

packages/eventlet/queue.py", line 265, in put 
    assert result is waiter, "Invalid switch into Queue.put: %r" % (result,) 
AssertionError: Invalid switch into Queue.put: ([16], [], []) 

Une idée de ce qui pourrait être la raison pour cela?

Merci.

Answer 1

La solution que j'ai trouvé à ce ajoutais eventlet.sleep() après:

queue.put(event) 
eventlet.sleep() 

espère que cela aidera tout le monde.