diff options
author | Nate Sesti <sestinj@gmail.com> | 2023-06-07 17:52:34 -0400 |
---|---|---|
committer | Nate Sesti <sestinj@gmail.com> | 2023-06-07 17:52:34 -0400 |
commit | 4e40ca34b780d2520579928e7ac04b60d68650fe (patch) | |
tree | e5f6d20fb5bdc647876c9333ea3a00c4aa7bf030 /continuedev | |
parent | 64e093f00bbac4d7a61b00fc4b178925c7a4a9ca (diff) | |
download | sncontinue-4e40ca34b780d2520579928e7ac04b60d68650fe.tar.gz sncontinue-4e40ca34b780d2520579928e7ac04b60d68650fe.tar.bz2 sncontinue-4e40ca34b780d2520579928e7ac04b60d68650fe.zip |
fixed duckdb table name
Diffstat (limited to 'continuedev')
-rw-r--r-- | continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py b/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py index 511abd1f..8c4ed8f7 100644 --- a/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py +++ b/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py @@ -134,7 +134,7 @@ class ValidatePipelineStep(Step): # load the data into the DuckDB instance await sdk.run(f'python3 {filename}', name="Load data into DuckDB", description=f"Running python3 {filename} to load data into DuckDB") - table_name = f"{source_name}.{source_name}_resource" + table_name = f"{source_name}_data.{source_name}_resource" tables_query_code = dedent(f'''\ import duckdb |