We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1f535f4 commit 63a1eb6Copy full SHA for 63a1eb6
1 file changed
sqlmesh/core/test/definition.py
@@ -645,15 +645,14 @@ def _create_df(
645
646
rows = values["rows"]
647
if columns:
648
+ columns = [str(c) for c in columns]
649
referenced_columns = list(dict.fromkeys(col for row in rows for col in row))
650
_raise_if_unexpected_columns(columns, referenced_columns)
651
652
if partial:
- columns = [str(c) for c in columns if str(c) in referenced_columns]
653
+ columns = [c for c in columns if c in referenced_columns]
654
- return pd.DataFrame.from_records(
655
- rows, columns=[str(c) for c in columns] if columns else None
656
- )
+ return pd.DataFrame.from_records(rows, columns=columns or None)
657
658
def _add_missing_columns(
659
self, query: exp.Query, all_columns: t.Optional[t.Collection[str]] = None
0 commit comments