diff options
| author | Nate Sesti <sestinj@gmail.com> | 2023-06-12 22:14:53 -0700 |
|---|---|---|
| committer | Nate Sesti <sestinj@gmail.com> | 2023-06-12 22:14:53 -0700 |
| commit | 34f2234e8be2b922876d2fcd519e3c124b397fd2 (patch) | |
| tree | 03a80dbe82c6dc52de28cb0f3d4e118a320d0952 /continuedev | |
| parent | b832660d7fa46064326a90439b70603a93c865c8 (diff) | |
| download | sncontinue-34f2234e8be2b922876d2fcd519e3c124b397fd2.tar.gz sncontinue-34f2234e8be2b922876d2fcd519e3c124b397fd2.tar.bz2 sncontinue-34f2234e8be2b922876d2fcd519e3c124b397fd2.zip | |
patch
Diffstat (limited to 'continuedev')
| -rw-r--r-- | continuedev/src/continuedev/recipes/DeployPipelineAirflowRecipe/steps.py | 4 |
1 files changed, 2 insertions, 2 deletions
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 ?? |