Searched defs:queue_name (Results 1 – 9 of 9) sorted by relevance
| /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 | handlers.py | 85 def _run_task_hook(hooks, method, task, queue_name): argument
983 queue_name): argument
1031 queue_name=None, argument
1323 queue_name=None): argument
1519 queue_name, argument
1705 queue_name, argument
1794 queue_name): argument
|
| D | control.py | 45 queue_name=None, argument
|
| D | util.py | 127 def get_queue_name(queue_name): argument
|
| D | model.py | 161 def add(self, queue_name, transactional=False): argument
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/manage/ |
| D | task.py | 58 def start_all(cls, queue_name): argument
143 def start(self, queue_name): argument
154 def __init__(self, queue_name): argument
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | map_job_config.py | 69 queue_name = _Option( variable in JobConfig
153 queue_name): argument
|
| /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
448 def get_queue(self, queue_name, owner_acct_id=None): argument
|
| /external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
| D | pipeline.py | 501 def queue_name(self): member in Pipeline
615 queue_name='default', argument
1322 def _generate_args(pipeline, future, queue_name, base_path): argument
1416 queue_name, argument
|