Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(35)

Side by Side Diff: appengine/components/components/datastore_utils/mapping.py

Issue 2013943002: Changing license header, again! (Closed) Base URL: git@github.com:luci/luci-py.git@master
Patch Set: Fixed third parties Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 # Copyright 2014 The LUCI Authors. All rights reserved. 1 # Copyright 2014 The LUCI Authors. All rights reserved.
2 # Use of this source code is governed by the Apache v2.0 license that can be 2 # Use of this source code is governed under the Apache License, Version 2.0
3 # found in the LICENSE file. 3 # that can be found in the LICENSE file.
4 4
5 """Queries for incremental mapping.""" 5 """Queries for incremental mapping."""
6 6
7 from google.appengine.ext import ndb 7 from google.appengine.ext import ndb
8 8
9 9
10 __all__ = [ 10 __all__ = [
11 'incremental_map', 11 'incremental_map',
12 'page_queries', 12 'page_queries',
13 'pop_future_done', 13 'pop_future_done',
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after
94 while len(items_to_process) >= map_page_size: 94 while len(items_to_process) >= map_page_size:
95 items_to_process = _process_chunk_of_items( 95 items_to_process = _process_chunk_of_items(
96 map_fn, action_futures, items_to_process, max_inflight, map_page_size) 96 map_fn, action_futures, items_to_process, max_inflight, map_page_size)
97 97
98 while items_to_process: 98 while items_to_process:
99 items_to_process = _process_chunk_of_items( 99 items_to_process = _process_chunk_of_items(
100 map_fn, action_futures, items_to_process, max_inflight, map_page_size) 100 map_fn, action_futures, items_to_process, max_inflight, map_page_size)
101 101
102 ndb.Future.wait_all(action_futures) 102 ndb.Future.wait_all(action_futures)
103 103
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698