| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | hooks.py | 40 def enqueue_worker_task(self, task, queue_name): argument
54 def enqueue_kickoff_task(self, task, queue_name): argument
70 def enqueue_done_task(self, task, queue_name): argument
87 def enqueue_controller_task(self, task, queue_name): argument
|
| D | util.py | 127 def get_queue_name(queue_name): argument
146 if queue_name:
147 return queue_name
148 queue_name = os.environ.get("HTTP_X_APPENGINE_QUEUENAME",
150 if len(queue_name) > 1 and queue_name[0:2] == "__":
154 return queue_name
|
| D | handlers.py | 85 def _run_task_hook(hooks, method, task, queue_name): argument
100 getattr(hooks, method)(task, queue_name)
743 queue_name = os.environ.get("HTTP_X_APPENGINE_QUEUENAME",
771 self._add_task(task, spec, queue_name)
983 queue_name): argument
996 queue_name):
1000 worker_task.add(queue_name)
1031 queue_name=None, argument
1047 queue_name = queue_name or os.environ.get("HTTP_X_APPENGINE_QUEUENAME",
1050 cls._add_task(task, tstate.mapreduce_spec, queue_name)
[all …]
|
| D | control.py | 45 queue_name=None, argument
102 mr_params["queue_name"] = util.get_queue_name(queue_name)
120 queue_name=mr_params["queue_name"],
|
| D | mapper_pipeline.py | 98 queue_name=self.queue_name,
|
| D | model.py | 161 def add(self, queue_name, transactional=False): argument
164 task.add(queue_name, transactional)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/sqs/ |
| D | test_bigmessage.py | 45 queue_name = 'test%d' % int(time.time())
47 queue = c.create_queue(queue_name, timeout)
53 bucket = s3.create_bucket(queue_name)
54 self.addCleanup(s3.delete_bucket, queue_name)
60 s3_url = 's3://%s' % queue_name
|
| D | test_connection.py | 57 queue_name = 'test%d' % int(time.time())
59 queue_1 = c.create_queue(queue_name, timeout)
134 queue_name = 'test%d' % int(time.time())
136 queue_2 = c.create_queue(queue_name, timeout)
157 queue_name = 'test_sqs_timeout_%s' % int(time.time())
158 queue = c.create_queue(queue_name)
190 queue_name = 'test_sqs_longpoll_%s' % int(time.time())
191 queue = c.create_queue(queue_name)
295 queue_name = 'test%d' % int(time.time())
296 test = conn.create_queue(queue_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/manage/ |
| D | task.py | 58 def start_all(cls, queue_name): argument
60 task.start(queue_name)
143 def start(self, queue_name): argument
144 boto.log.info('Task[%s] - starting with queue: %s' % (self.name, queue_name))
145 queue = boto.lookup('sqs', queue_name)
154 def __init__(self, queue_name): argument
156 self.queue = self.sqs.lookup(queue_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/bin/ |
| D | cq | 39 queue_name = ''
49 queue_name = a
65 if queue_name:
67 rs = [c.create_queue(queue_name)]
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | map_job_config.py | 69 queue_name = _Option( variable in JobConfig
130 "queue_name": self.queue_name,
153 queue_name): argument
202 queue_name=queue_name,
|
| D | map_job_control.py | 42 queue_name=state.mapreduce_spec.params.get("queue_name"))
228 hooks.enqueue_kickoff_task(kickoff_task, job_config.queue_name)
232 kickoff_task.add(job_config.queue_name, transactional=True)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/sns/ |
| D | test_sns_sqs_subscription.py | 53 topic_name = queue_name = "test_correct_sid%d" % (now)
56 queue = self.sqsc.create_queue(queue_name, timeout)
78 topic_name = queue_name = "test_idempotent_subscribe%d" % (now)
81 queue = self.sqsc.create_queue(queue_name, timeout)
|
| /external/chromium-trace/catapult/dashboard/dashboard/ |
| D | change_internal_only.py | 106 queue_name=_QUEUE_NAME)
137 queue_name=_QUEUE_NAME)
147 queue_name=_QUEUE_NAME)
189 queue_name=_QUEUE_NAME)
|
| D | migrate_test_names.py | 168 queue_name=_TASK_QUEUE_NAME)
273 queue_name=_TASK_QUEUE_NAME)
|
| D | edit_config_handler.py | 229 queue_name=_TASK_QUEUE_NAME)
|
| D | stats.py | 274 queue_name=_QUEUE_NAME)
308 queue_name=_QUEUE_NAME)
|
| D | auto_triage.py | 119 queue_name=_TASK_QUEUE_NAME)
|
| D | bench_find_anomalies.py | 414 stage.start(queue_name=_TASK_QUEUE_NAME)
|
| /external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
| D | pipeline.py | 501 def queue_name(self): member in Pipeline
504 return self._context.queue_name
615 queue_name='default', argument
660 context = _PipelineContext('', queue_name, base_path)
956 taskqueue.Queue(self.queue_name).add(task)
1322 def _generate_args(pipeline, future, queue_name, base_path): argument
1356 'queue_name': queue_name,
1416 queue_name, argument
1428 self.queue_name = queue_name
1502 task.add(queue_name=self.queue_name, transactional=True)
[all …]
|
| D | common.py | 351 task.add(self.queue_name)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/sqs/ |
| D | connection.py | 68 def create_queue(self, queue_name, visibility_timeout=None): argument
92 params = {'QueueName': queue_name}
448 def get_queue(self, queue_name, owner_acct_id=None): argument
458 params = {'QueueName': queue_name}
|
| /external/chromium-trace/catapult/perf_insights/perf_insights/endpoints/cloud_mapper/ |
| D | task.py | 85 queue_name='mapper-queue',
102 queue_name='default',
182 queue_name='mapper-queue',
207 queue_name='default',
|