イベントレットはqueue.putで例外をアサートします

Question

イベントレット/キューを挿入しようとしているときに時折奇妙な例外が発生します。

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], [], []) 

どのような理由が考えられますか？

ありがとうございました。私はこれを見つけた

Answer 1

ソリューションは、後にeventlet.sleep（）を追加しました：

queue.put(event) 
eventlet.sleep() 

それが誰を助けることを願っています。