| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| test_support.py | 45 task: a dict representing a taskqueue task as documented in taskqueue_stub.
70 task: a taskqueue task.
119 # Set taskqueue specific headers and env vars.
175 def execute_all_tasks(taskqueue, queue="default", handlers_map=None):
176 """Run and remove all tasks in the taskqueue.
179 taskqueue: An instance of taskqueue stub.
187 tasks = taskqueue.GetTasks(queue)
188 taskqueue.FlushQueue(queue)
214 def execute_until_empty(taskqueue, queue="default", handlers_map=None)
[all...] |
| handlers.py | 44 from google.appengine.api import taskqueue namespace
92 task: The taskqueue.Task to pass to the hook method.
165 tstate: model.TransientShardState from taskqueue paylod.
206 # Taskqueue executes old successful tasks.
231 # TODO(user): There might be a better way. Taskqueue's countdown
349 2. _attempt_slice_retry: may raise exception to taskqueue.
350 3. _save_state_and_schedule_next: may raise exception when taskqueue/db
547 All other exceptions will be logged and raised to taskqueue for retry
742 # Prepare parameters for db transaction and taskqueue.
765 # This way we guarantee taskqueue is never behind datastore states
[all...] |
| model.py | 52 from google.appengine.api import taskqueue namespace
83 """HugeTask is a taskqueue.Task-like class that can store big payloads.
93 MAX_TASK_PAYLOAD = taskqueue.MAX_PUSH_TASK_SIZE_BYTES - 1024
167 """Convert to a taskqueue task."""
168 # Never pass params to taskqueue.Task. Use payload instead. Otherwise,
169 # it's up to a particular taskqueue implementation to generate
171 return taskqueue.Task(
908 processing data when lock is held. Taskqueue/datastore errors
[all...] |
| /external/chromium-trace/catapult/dashboard/dashboard/ |
| delete_test_data.py | 20 from google.appengine.api import taskqueue namespace
119 taskqueue.add(
140 taskqueue.add(
|
| change_internal_only.py | 9 from google.appengine.api import taskqueue namespace
101 taskqueue.add(
134 taskqueue.add(
143 taskqueue.add(
185 taskqueue.add(
|
| edit_config_handler.py | 7 from google.appengine.api import taskqueue namespace
232 taskqueue.add(
|
| mr.py | 26 from google.appengine.api import taskqueue namespace
116 taskqueue.add(
|
| migrate_test_names.py | 23 from google.appengine.api import taskqueue namespace
163 taskqueue.add(
268 taskqueue.add(
|
| auto_triage.py | 14 from google.appengine.api import taskqueue namespace
121 taskqueue.add(
|
| add_point.py | 14 from google.appengine.api import taskqueue namespace
257 task_list.append(taskqueue.Task(
260 queue = taskqueue.Queue(_TASK_QUEUE_NAME)
261 for task_sublist in _Chunk(task_list, taskqueue.MAX_TASKS_PER_ADD):
|
| /external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
| common.py | 24 from google.appengine.api import taskqueue namespace
352 except (taskqueue.TombstonedTaskError, taskqueue.TaskAlreadyExistsError):
|
| pipeline.py | 46 from google.appengine.api import taskqueue namespace
628 mounted for access by the taskqueue API or external requests.
643 A taskqueue.Task instance if return_task was True. This task will *not*
860 args, kwargs: Passed to the taskqueue.Task constructor. Use these
864 A taskqueue.Task instance that must be enqueued by the caller.
875 return taskqueue.Task(*args, **kwargs)
[all...] |
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| map_job_control.py | 4 from google.appengine.api import taskqueue namespace
212 """Add kickoff task to taskqueue.
220 kickoff_task = taskqueue.Task(
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| pool.py | 332 def _handle_tasks(taskqueue, put, outqueue, pool):
335 for taskseq, set_length in iter(taskqueue.get, None):
473 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool,
|
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| pool.py | 332 def _handle_tasks(taskqueue, put, outqueue, pool):
335 for taskseq, set_length in iter(taskqueue.get, None):
473 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool,
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 332 def _handle_tasks(taskqueue, put, outqueue, pool):
335 for taskseq, set_length in iter(taskqueue.get, None):
473 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool,
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 332 def _handle_tasks(taskqueue, put, outqueue, pool):
335 for taskseq, set_length in iter(taskqueue.get, None):
473 def _terminate_pool(cls, taskqueue, inqueue, outqueue, pool,
|
