Home
last modified time | relevance | path

Searched refs:pipeline_id (Results 1 – 7 of 7) sorted by relevance

/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/datapipeline/
Dtest_layer1.py59 pipeline_id = response['pipelineId']
60 self.addCleanup(self.connection.delete_pipeline, pipeline_id)
61 return pipeline_id
63 def get_pipeline_state(self, pipeline_id): argument
64 response = self.connection.describe_pipelines([pipeline_id])
75 pipeline_id = self.create_pipeline('name2', 'unique_id2')
78 self.sample_pipeline_objects, pipeline_id)
81 pipeline_id = self.create_pipeline('name3', 'unique_id3')
83 pipeline_id)
87 response = self.connection.get_pipeline_definition(pipeline_id)
[all …]
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/elastictranscoder/
Dtest_layer1.py59 pipeline_id = pipeline['Pipeline']['Id']
61 self.addCleanup(self.api.delete_pipeline, pipeline_id)
62 return pipeline_id
69 pipeline_id = pipeline['Pipeline']['Id']
71 self.api.delete_pipeline(pipeline_id)
74 pipeline_id = self.create_pipeline()
82 response = self.api.read_pipeline(pipeline_id)
83 self.assertEqual(response['Pipeline']['Id'], pipeline_id)
86 pipeline_id = self.create_pipeline()
87 self.api.update_pipeline_status(pipeline_id, 'Paused')
[all …]
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/datapipeline/
Dlayer1.py98 def activate_pipeline(self, pipeline_id): argument
112 params = {'pipelineId': pipeline_id, }
153 def delete_pipeline(self, pipeline_id): argument
171 params = {'pipelineId': pipeline_id, }
175 def describe_objects(self, object_ids, pipeline_id, marker=None, argument
205 'pipelineId': pipeline_id,
240 def evaluate_expression(self, pipeline_id, expression, object_id): argument
257 'pipelineId': pipeline_id,
264 def get_pipeline_definition(self, pipeline_id, version=None): argument
281 params = {'pipelineId': pipeline_id, }
[all …]
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/elastictranscoder/
Dlayer1.py81 def create_job(self, pipeline_id=None, input_name=None, output=None, argument
129 if pipeline_id is not None:
130 params['PipelineId'] = pipeline_id
455 def list_jobs_by_pipeline(self, pipeline_id=None, ascending=None, argument
480 uri = '/2012-09-25/jobsByPipeline/{0}'.format(pipeline_id)
482 if pipeline_id is not None:
483 params['PipelineId'] = pipeline_id
/external/chromium-trace/catapult/third_party/pipeline/pipeline/
Dpipeline.py482 def pipeline_id(self): member in Pipeline
544 def from_id(cls, pipeline_id, resolve_outputs=True, _pipeline_record=None): argument
566 if not isinstance(pipeline_id, unicode):
568 pipeline_id = pipeline_id.encode('utf-8')
570 pipeline_id = hashlib.sha1(pipeline_id).hexdigest()
572 pipeline_key = db.Key.from_path(_PipelineRecord.kind(), pipeline_id)
584 pipeline_record.class_path, pipeline_id)
789 self, self.pipeline_id, message, console_url, status_links)
792 status_key = db.Key.from_path(_StatusRecord.kind(), self.pipeline_id)
815 (self, self.pipeline_id, str(e)))
[all …]
Dcommon.py349 name='ae-pipeline-delay-' + self.pipeline_id)
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmapper_pipeline.py94 "pipeline_id": self.pipeline_id,