summaryrefslogtreecommitdiff
path: root/continuedev/src
diff options
context:
space:
mode:
authorNate Sesti <sestinj@gmail.com>2023-06-19 18:25:26 -0700
committerNate Sesti <sestinj@gmail.com>2023-06-19 18:25:26 -0700
commite37874dc89c0ef367465070394196a64245f4349 (patch)
treee67eb4eda5a046ec9152650ff498596471ec1f48 /continuedev/src
parent3e2dc24a448b27f551a3c9f2042bfcb4d15edc63 (diff)
parent1d6f7f4e2ed6a5910e0fd0f71d3b0d2a43749882 (diff)
downloadsncontinue-e37874dc89c0ef367465070394196a64245f4349.tar.gz
sncontinue-e37874dc89c0ef367465070394196a64245f4349.tar.bz2
sncontinue-e37874dc89c0ef367465070394196a64245f4349.zip
Merge branch 'main' of https://github.com/continuedev/continue
Diffstat (limited to 'continuedev/src')
-rw-r--r--continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py10
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")