

def run(self):
    'The body of the tread: read lines and put them on the queue.'
    for line in iter(self._fd.readline, ''):
        line._queue.put(line)

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py AsynchronousFileReader.run/VarMisuse@28/59 `self`->`line`