diff options
| author | Ty Dunn <ty@tydunn.com> | 2023-06-19 18:22:56 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-06-19 18:22:56 -0700 |
| commit | 7e2fbb5d443606d167cd2062129a6af51348a1dd (patch) | |
| tree | dffd32cf8c59d2f119aa517710f9580a8cdb993d /continuedev/src/continuedev/recipes/CreatePipelineRecipe/steps.py | |
| parent | a397abef8e5124edc0079c61dfcf546998cac5c9 (diff) | |
| parent | e39f06127e795d2a14fbc9ed569f3b7ee6befe93 (diff) | |
| download | sncontinue-7e2fbb5d443606d167cd2062129a6af51348a1dd.tar.gz sncontinue-7e2fbb5d443606d167cd2062129a6af51348a1dd.tar.bz2 sncontinue-7e2fbb5d443606d167cd2062129a6af51348a1dd.zip | |
Merge pull request #129 from continuedev/dlt
changing to DESCRIBE tables
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") |