From ee96c20034f1693521fbbc9927e860ad621a2d65 Mon Sep 17 00:00:00 2001 From: Andrii Piasetskyi Date: Sun, 23 Apr 2017 19:20:10 +0300 Subject: [PATCH] Added description and tags for create_pipeline --- moto/datapipeline/models.py | 2 +- moto/datapipeline/responses.py | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/moto/datapipeline/models.py b/moto/datapipeline/models.py index e7abe439b..20fc4b12b 100644 --- a/moto/datapipeline/models.py +++ b/moto/datapipeline/models.py @@ -26,7 +26,7 @@ class Pipeline(BaseModel): def __init__(self, name, unique_id, **kwargs): self.name = name self.unique_id = unique_id - self.description = "" + self.description = kwargs.get('description', '') self.pipeline_id = get_random_pipeline_id() self.creation_time = datetime.datetime.utcnow() self.objects = [] diff --git a/moto/datapipeline/responses.py b/moto/datapipeline/responses.py index 9250bce54..e75367c49 100644 --- a/moto/datapipeline/responses.py +++ b/moto/datapipeline/responses.py @@ -21,10 +21,11 @@ class DataPipelineResponse(BaseResponse): return datapipeline_backends[self.region] def create_pipeline(self): - name = self.parameters['name'] - unique_id = self.parameters['uniqueId'] + name = self.parameters.get('name') + unique_id = self.parameters.get('uniqueId') + description = self.parameters.get('description', '') tags = self.parameters.get('tags', []) - pipeline = self.datapipeline_backend.create_pipeline(name, unique_id, tags=tags) + pipeline = self.datapipeline_backend.create_pipeline(name, unique_id, description=description, tags=tags) return json.dumps({ "pipelineId": pipeline.pipeline_id, })