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 | baf084ae08377fafe6e147320454a6110cd5765e (patch) | |
| tree | 27e4c02316d37002eda7a45c3a0d4167118c3935 /continuedev | |
| parent | 0a7ca710ae4af16933ef128d13c050b99912e71a (diff) | |
| download | sncontinue-baf084ae08377fafe6e147320454a6110cd5765e.tar.gz sncontinue-baf084ae08377fafe6e147320454a6110cd5765e.tar.bz2 sncontinue-baf084ae08377fafe6e147320454a6110cd5765e.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 ?? |