Skip to content

Commit 8da6f5a

Browse files
tabletype is 5th col
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent 2b8b4c4 commit 8da6f5a

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

examples/experimental/sea_connector_test.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,7 +194,7 @@ def test_sea_result_set_json_array_inline():
194194
log_metadata_results("columns", columns, logger)
195195

196196
# Extract column names
197-
column_names = extract_key_values(columns, "column_name") or extract_key_values(columns, "columnName") or extract_key_values(columns, "COLUMN_NAME")
197+
column_names = extract_key_values(columns, "col_name")
198198
if column_names:
199199
logger.info(f"Column names: {column_names}")
200200

src/databricks/sql/backend/filters.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ def filter_tables_by_type(
153153
table_types if table_types and len(table_types) > 0 else DEFAULT_TABLE_TYPES
154154
)
155155

156-
# Table type is typically in the 4th column (index 3)
156+
# Table type is the 6th column (index 5)
157157
return ResultSetFilter.filter_by_column_values(
158-
result_set, 3, valid_types, case_sensitive=False
158+
result_set, 5, valid_types, case_sensitive=False
159159
)

src/databricks/sql/backend/sea_backend.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -622,10 +622,9 @@ def get_tables(
622622
)
623623
assert result is not None, "execute_command returned None in synchronous mode"
624624

625-
# # Apply client-side filtering by table_types if specified
626-
# from databricks.sql.backend.filters import ResultSetFilter
627-
628-
# result = ResultSetFilter.filter_tables_by_type(result, table_types)
625+
# Apply client-side filtering by table_types if specified
626+
from databricks.sql.backend.filters import ResultSetFilter
627+
result = ResultSetFilter.filter_tables_by_type(result, table_types)
629628

630629
return result
631630

0 commit comments

Comments
 (0)