def METHOD_NAME(self):
    pipeline_id = self.create_pipeline('name3', 'unique_id3')
    self.connection.put_pipeline_definition(self.sample_pipeline_objects,
                                            pipeline_id)
    # We should now be able to get the pipeline definition and see
    # that it matches what we put.
    response = self.connection.get_pipeline_definition(pipeline_id)
    objects = response['pipelineObjects']
    self.assertEqual(len(objects), 3)
    self.assertEqual(objects[0]['id'], 'Default')
    self.assertEqual(objects[0]['name'], 'Default')
    self.assertEqual(objects[0]['fields'],
                     [{'key': 'workerGroup', 'stringValue': 'MyworkerGroup'}])