From baf084ae08377fafe6e147320454a6110cd5765e Mon Sep 17 00:00:00 2001
From: Nate Sesti <sestinj@gmail.com>
Date: Mon, 12 Jun 2023 22:14:53 -0700
Subject: patch
---
.../src/continuedev/recipes/DeployPipelineAirflowRecipe/steps.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
(limited to 'continuedev')
diff --git a/continuedev/src/continuedev/recipes/DeployPipelineAirflowRecipe/steps.py b/continuedev/src/continuedev/recipes/DeployPipelineAirflowRecipe/steps.py
index 500a89ba..ee3275e7 100644
--- a/continuedev/src/continuedev/recipes/DeployPipelineAirflowRecipe/steps.py
+++ b/continuedev/src/continuedev/recipes/DeployPipelineAirflowRecipe/steps.py
@@ -74,7 +74,7 @@ class DeployAirflowStep(Step):
pipeline_filepath = os.path.join(
directory, f"{self.source_name}_pipeline.py")
dag_filepath = os.path.join(
- directory, f"dags/dag_{self.source_name}.py")
+ directory, f"dags/dag_{self.source_name}_pipeline.py")
# Replace the pipeline name and dataset name
await sdk.run_step(FindAndReplaceStep(filepath=pipeline_filepath, pattern="'pipeline_name'", replacement=f"'{self.source_name}_pipeline'"))
@@ -89,6 +89,6 @@ class DeployAirflowStep(Step):
range=edit_dag_range)
# Tell the user to check the schedule and fill in owner, email, other default_args
- await sdk.run_step(MessageStep(message="Fill in the owner, email, and other default_args in the DAG file with your own personal information.", name="Fill in default_args"))
+ await sdk.run_step(MessageStep(message="Fill in the owner, email, and other default_args in the DAG file with your own personal information. Then the DAG will be ready to run!", name="Fill in default_args"))
# Run the DAG locally ??
--
cgit v1.2.3-70-g09d2