| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/swf/ |
| D | layer1_decisions.py | 20 task_list=None, argument
59 if task_list is not None:
60 attrs['taskList'] = {'name': task_list}
148 task_list=None, argument
167 if task_list is not None:
168 attrs['taskList'] = {'name': task_list}
257 task_list=None, argument
283 if task_list is not None:
284 attrs['taskList'] = {'name': task_list}
|
| D | layer1.py | 149 def poll_for_activity_task(self, domain, task_list, identity=None): argument
179 'taskList': {'name': task_list},
275 def poll_for_decision_task(self, domain, task_list, identity=None, argument
321 'taskList': {'name': task_list},
388 task_list=None, child_policy=None, argument
472 'taskList': {'name': task_list},
582 def register_activity_type(self, domain, name, version, task_list=None, argument
653 'defaultTaskList': {'name': task_list},
689 task_list=None, argument
762 'defaultTaskList': {'name': task_list},
[all …]
|
| D | layer2.py | 140 def count_pending_activity_tasks(self, task_list): argument
142 return self._swf.count_pending_activity_tasks(self.name, task_list)
145 def count_pending_decision_tasks(self, task_list): argument
147 return self._swf.count_pending_decision_tasks(self.name, task_list)
152 task_list = None variable in Actor
196 task_list = self.task_list
198 task_list = kwargs.get('task_list')
200 task = self._swf.poll_for_activity_task(self.domain, task_list,
223 task_list = self.task_list
225 task_list = kwargs.get('task_list')
[all …]
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/swf/ |
| D | test_layer2_actors.py | 11 self.worker = ActivityWorker(name='test-worker', domain='test', task_list='test_list')
12 self.decider = Decider(name='test-worker', domain='test', task_list='test_list')
79 self.worker.poll(task_list='some_other_tasklist')
83 self.decider.poll(task_list='some_other_tasklist')
|
| D | test_layer1_decisions.py | 20 task_list='tasklist',
|
| D | test_layer2_types.py | 38 execution = wf_type.start(task_list='hello_world')
|
| /external/autotest/site_utils/suite_scheduler/ |
| D | driver.py | 85 for keyword, task_list in tasks.iteritems():
87 events[keyword].tasks = task_list
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/swf/ |
| D | test_layer1.py | 106 task_list=self._task_list,
123 task_list=self._task_list,
|
| D | test_layer1_workflow_execution.py | 59 task_list=self._task_list,
|
| /external/chromium-trace/catapult/dashboard/dashboard/ |
| D | add_point.py | 255 task_list = []
257 task_list.append(taskqueue.Task(
261 for task_sublist in _Chunk(task_list, taskqueue.MAX_TASKS_PER_ADD):
|
| /external/autotest/site_utils/ |
| D | collect_suite_time_stats.py | 141 def get_tasks_runtime(task_list, dut, t_start, job_id, job_info_dict): argument
161 batch_constraints=[('task_id', task_list)])
|
| /external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
| D | pipeline.py | 1577 task_list = []
1613 task_list.append(taskqueue.Task(
1638 task_list.append(taskqueue.Task(
1646 if task_list:
1648 taskqueue.Queue(self.queue_name).add(task_list)
1724 task_list = []
1731 task_list.append(taskqueue.Task(
1746 task_list.append(taskqueue.Task(
1752 if task_list:
1754 taskqueue.Queue(self.queue_name).add(task_list)
|