@staticmethod
    def _watch_futures(futures, result_queue):
        futures_only = list(futures.keys())
        for f in interruptable_as_completed(futures_only):
            try:
                r = f.result()
                if r is not None:
                    result_queue.put(r)
            except CancelledError:
                details = futures[f]
                res = details
                res['status'] = 'cancelled'
                result_queue.put(res)
            except Exception as err:
                traceback, err_time = report_traceback()
                logger.exception(err)
                details = futures[f]
                res = details
                res.update({
                    'success': False,
                    'error': err,
                    'traceback': traceback,
                    'error_timestamp': err_time
                })
                result_queue.put(res)

        result_queue.put(None)
If the given assetstore has an effective user specified, this returns
dataset/ETHPy150Open openstack/python-swiftclient/swiftclient/service.py/SwiftService._watch_futures--crossover with--dataset/ETHPy150Open girder/girder/plugins/hdfs_assetstore/server/assetstore.py/HdfsAssetstoreAdapter._getHdfsUser