

def _publish(self, data):
    with self.writer_conn.SimpleQueue(self.writer_queue) as queue:
        self.put(pickle.dumps(data))

dataset/ETHPy150Open miguelgrinberg/python-socketio/socketio/kombu_manager.py KombuManager._publish/VarMisuse@28/34 `queue`->`self`