def _get(self, *args, **kwargs):

        if 'timeout' not in kwargs:
            kwargs['timeout'] = self.timeout

        req = self.session.get(*args, **kwargs)
        return req
Flush(apply) all changed to datastore.
dataset/ETHPy150Open pycontribs/python-crowd/crowd.py/CrowdServer._get--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/src/mapreduce/context.py/_MutationPool.flush