docs: def create_datapipeline(self):
          """Creates data pipeline and adds definition"""
          utils.banner("Creating Data Pipeline")
          dpobj = datapipeline.AWSDataPipeline(app=self.app, env=self.env, region=self.region, prop_path=self.json_path)
          dpobj.create_datapipeline()
          dpobj.set_pipeline_definition()
          if self.configs[self.env].get('datapipeline').get('activate_on_deploy'):
              dpobj.activate_pipeline()