in workflows-generator/ComposerDagGenerator.py [0:0]
def load_templates(self):
"""method for loading templates"""
self.workflow_template = read_template("workflow", self.generate_for_pipeline, "composer-templates", "py")
self.level_template = read_template("level", self.generate_for_pipeline, "composer-templates", "py")
self.thread_template = read_template("thread", self.generate_for_pipeline, "composer-templates", "py")
# add new templates for other executors here
self.dataform_tag_executor_template = read_template("dataform_tag_executor", self.generate_for_pipeline,
"composer-templates", "py")
self.dataflow_flextemplate_job_executor_template = read_template("dataflow_flextemplate_job_executor",
self.generate_for_pipeline,
"composer-templates", "py")
self.dataproc_serverless_job_executor_template = read_template("dataproc_serverless_job_executor",
self.generate_for_pipeline, "composer-templates",
"py")