summaryrefslogtreecommitdiff
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
commit62f37981755471a8fab4226083d36819025b8d2e (patch)
tree42510fd9c62fb3754cd720237d3896025a7d5703
parentefdb736f8af3372dfc0ef66f418eac323860d7b2 (diff)
parent7e2fbb5d443606d167cd2062129a6af51348a1dd (diff)
downloadsncontinue-62f37981755471a8fab4226083d36819025b8d2e.tar.gz
sncontinue-62f37981755471a8fab4226083d36819025b8d2e.tar.bz2
sncontinue-62f37981755471a8fab4226083d36819025b8d2e.zip
Merge branch 'main' of https://github.com/continuedev/continue
-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")