| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| hooks.py | 40 def enqueue_worker_task(self, task, queue_name):
46 queue_name: The queue where the task should be run e.g. "default".
54 def enqueue_kickoff_task(self, task, queue_name):
62 queue_name: The queue where the task should be run e.g. "default".
70 def enqueue_done_task(self, task, queue_name):
79 queue_name: The queue where the task should be run e.g. "default".
87 def enqueue_controller_task(self, task, queue_name):
93 queue_name: The queue where the task should be run e.g. "default".
|
| control.py | 45 queue_name=None,
71 queue_name: taskqueue queue name to be used for mapreduce tasks.
102 mr_params["queue_name"] = util.get_queue_name(queue_name)
118 # TODO(user): Now that "queue_name" is part of mr_params.
119 # Remove all the other ways to get queue_name after one release.
120 queue_name=mr_params["queue_name"],
|
| util.py | 127 def get_queue_name(queue_name):
137 "queue_name" argument. The pipeline will run on that queue and MR will
138 simply inherit the queue_name.
141 queue_name: queue_name from user. Maybe None.
146 if queue_name:
147 return queue_name
148 queue_name = os.environ.get("HTTP_X_APPENGINE_QUEUENAME",
149 parameters.config.QUEUE_NAME)
150 if len(queue_name) > 1 and queue_name[0:2] == "__"
[all...] |
| mapper_pipeline.py | 98 queue_name=self.queue_name,
|
| handlers.py | 85 def _run_task_hook(hooks, method, task, queue_name):
86 """Invokes hooks.method(task, queue_name).
93 queue_name: The name of the queue to pass to the hook method.
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)
[all...] |
| model.py | 161 def add(self, queue_name, transactional=False):
164 task.add(queue_name, transactional)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/sqs/ |
| 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
|
| 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)
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/bin/ |
| cq | 29 print 'cq [-c] [-q queue_name] [-o output_file] [-t timeout] [-r region]'
39 queue_name = ''
49 queue_name = a
65 if queue_name:
67 rs = [c.create_queue(queue_name)]
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/sns/ |
| 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/third_party/gsutil/third_party/boto/boto/manage/ |
| task.py | 58 def start_all(cls, queue_name):
60 task.start(queue_name)
143 def start(self, queue_name):
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):
156 self.queue = self.sqs.lookup(queue_name)
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| map_job_config.py | 69 queue_name = _Option( variable in class:JobConfig
70 basestring, default_factory=lambda: parameters.config.QUEUE_NAME)
130 "queue_name": self.queue_name,
153 queue_name):
162 queue_name: queue name.
202 queue_name=queue_name,
|
| 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/dashboard/dashboard/ |
| delete_test_data.py | 122 queue_name=_TASK_QUEUE_NAME)
143 queue_name=_TASK_QUEUE_NAME)
|
| change_internal_only.py | 107 queue_name=_QUEUE_NAME)
140 queue_name=_QUEUE_NAME)
150 queue_name=_QUEUE_NAME)
192 queue_name=_QUEUE_NAME)
|
| edit_config_handler.py | 235 queue_name=_TASK_QUEUE_NAME,
|
| mr.py | 123 queue_name=_DELETE_TASK_QUEUE_NAME)
|
| migrate_test_names.py | 166 queue_name=_TASK_QUEUE_NAME)
271 queue_name=_TASK_QUEUE_NAME)
|
| auto_triage.py | 124 queue_name=_TASK_QUEUE_NAME)
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/sqs/ |
| connection.py | 68 def create_queue(self, queue_name, visibility_timeout=None):
72 :type queue_name: str or unicode
73 :param queue_name: The name of the new queue. Names are
92 params = {'QueueName': queue_name}
448 def get_queue(self, queue_name, owner_acct_id=None):
453 :param str queue_name: The name of the queue to retrieve.
458 params = {'QueueName': queue_name}
|
| /external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
| pipeline.py | 421 queue_name: The queue this pipeline runs on or None if unknown.
501 def queue_name(self): member in class:Pipeline
504 return self._context.queue_name
604 _PipelineContext('', params['queue_name'], params['base_path']),
615 queue_name='default',
626 queue_name: What queue this Pipeline's workflow should execute on.
660 context = _PipelineContext('', queue_name, base_path)
[all...] |
| common.py | 351 task.add(self.queue_name)
|
