def _stream_files(logger, fn, mesos_files, line_prefixes):
    reachable_files = list(mesos_files)

    # TODO switch to map
    for job, mesos_file in util.stream(fn, mesos_files):
        try:
            lines = job.result()
        except DCOSException:
            # The read function might throw an exception if read.json
            # is unavailable, or if the file doesn't exist in the
            # sandbox.  In any case, we silently remove the file and
            # continue.
            reachable_files.remove(mesos_file)
            continue

        if lines:
            _output(logger,
                    str(mesos_file),
                    lines,
                    line_prefixes)

    return reachable_files
Allow the user to pay the remaining balance.
dataset/ETHPy150Open shopkeep/shpkpr/shpkpr/files.py/_stream_files--crossover with--dataset/ETHPy150Open dokterbob/satchmo/satchmo/apps/payment/views/balance.py/balance_remaining