meharji arumilli
10/11/2023, 5:22 AMconf/
at /home/ec2-user/
. So, conf/
is copied to /home/ec2-user/
. And now there is a second project and its .whl is also installed at AWS Linux instance, and when its corresponding DAG is run, it again looks at /home/ec2-user/conf
. Here the parameters inside conf/
are different for project1 and project2. How can it be done to have conf/
specific to each DAG?Ankita Katiyar
10/11/2023, 3:53 PMclass KedroOperator(BaseOperator):
@apply_defaults
def __init__(
self,
package_name: str,
pipeline_name: str,
node_name: str,
project_path: str,
env: str,
*args, **kwargs
) -> None:
super().__init__(*args, **kwargs)
self.package_name = package_name
self.pipeline_name = pipeline_name
self.node_name = node_name
self.project_path = project_path
self.env = env
def execute(self, context):
configure_project(self.package_name)
with KedroSession.create(self.package_name,
self.project_path,
env=self.env,
conf_source=<path to conf_source>) as session: #ADD CONF SOURCE here
session.run(self.pipeline_name, node_names=[self.node_name])