def _pollWriteQueue(self):
        self._write_task = self._write_queue.get()
        self._write_task.addCallback(self._writeData)
Try pulling data from this circuit's write_queue and add a
dataset/ETHPy150Open nskinkel/oppy/oppy/circuit/circuit.py/Circuit._pollWriteQueue