Implement CloudFormation's physical_resource_id for Data Pipeline

getmoto · Sep 17, 2015 · dafddb0 · dafddb0
1 parent 8623483
commit dafddb0
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/moto/datapipeline/models.py b/moto/datapipeline/models.py
@@ -30,6 +30,10 @@ def __init__(self, name, unique_id):
         self.objects = []
         self.status = "PENDING"
 
+    @property
+    def physical_resource_id(self):
+        return self.pipeline_id
+
     def to_meta_json(self):
         return {
             "id": self.pipeline_id,

diff --git a/tests/test_cloudformation/test_cloudformation_stack_integration.py b/tests/test_cloudformation/test_cloudformation_stack_integration.py
@@ -1462,7 +1462,7 @@ def test_datapipeline():
     }
     cf_conn = boto.cloudformation.connect_to_region("us-east-1")
     template_json = json.dumps(dp_template)
-    cf_conn.create_stack(
+    stack_id = cf_conn.create_stack(
         "test_stack",
         template_body=template_json,
     )
@@ -1472,3 +1472,7 @@ def test_datapipeline():
 
     data_pipelines['pipelineIdList'].should.have.length_of(1)
     data_pipelines['pipelineIdList'][0]['name'].should.equal('testDataPipeline')
+
+    stack_resources = cf_conn.list_stack_resources(stack_id)
+    stack_resources.should.have.length_of(1)
+    stack_resources[0].physical_resource_id.should.equal(data_pipelines['pipelineIdList'][0]['id'])