diff options
author | Nate Sesti <sestinj@gmail.com> | 2023-06-26 16:39:07 -0700 |
---|---|---|
committer | Nate Sesti <sestinj@gmail.com> | 2023-06-26 16:39:07 -0700 |
commit | f3c6533d4054de5a71c8867c2b76fc8b0747447c (patch) | |
tree | 8e53ce9533aa42ee5d0a31504aa07be691d87157 /continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py | |
parent | f403bbe26b8864ff5367eab08afe4a01fdde8e72 (diff) | |
parent | 292d4d10ce28d720d61f97918c490b0d9cdae9e7 (diff) | |
download | sncontinue-f3c6533d4054de5a71c8867c2b76fc8b0747447c.tar.gz sncontinue-f3c6533d4054de5a71c8867c2b76fc8b0747447c.tar.bz2 sncontinue-f3c6533d4054de5a71c8867c2b76fc8b0747447c.zip |
Merge branch 'main' into styled-code
Diffstat (limited to 'continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py')
-rw-r--r-- | continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py b/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py index 91515dc2..60218ef9 100644 --- a/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py +++ b/continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py @@ -139,14 +139,8 @@ class ValidatePipelineStep(Step): # connect to DuckDB instance conn = duckdb.connect(database="{source_name}.duckdb") - conn.execute("SET search_path = '{source_name}_data';") - - # get table names - rows = conn.execute("SELECT * FROM _dlt_loads;").fetchall() - - # print table names - for row in rows: - print(row)''') + # list all tables + print(conn.sql("DESCRIBE"))''') query_filename = os.path.join(workspace_dir, "query.py") await sdk.apply_filesystem_edit(AddFile(filepath=query_filename, content=tables_query_code), name="Add query.py file", description="Adding a file called `query.py` to the workspace that will run a test query on the DuckDB instance") |