Skip to content

Commit 6c20e4d

Browse files
committed
fix mypy errors for newer pandas
1 parent ec0f2e3 commit 6c20e4d

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

sqlmesh/core/test/definition.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -648,7 +648,9 @@ def _create_df(
648648
if partial:
649649
columns = referenced_columns
650650

651-
return pd.DataFrame.from_records(rows, columns=columns)
651+
return pd.DataFrame.from_records(
652+
rows, columns=[str(c) for c in columns] if columns else None
653+
)
652654

653655
def _add_missing_columns(
654656
self, query: exp.Query, all_columns: t.Optional[t.Collection[str]] = None

tests/integrations/github/cicd/test_integration.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,9 @@ def get_environment_objects(controller: GithubController, environment: str) -> t
3737

3838

3939
def get_num_days_loaded(controller: GithubController, environment: str, model: str) -> int:
40-
return int(
41-
controller._context.engine_adapter.fetchdf(
42-
f"SELECT distinct event_date FROM sushi__{environment}.{model}"
43-
).count()
44-
)
40+
return controller._context.engine_adapter.fetchdf(
41+
f"SELECT distinct event_date FROM sushi__{environment}.{model}"
42+
).shape[0]
4543

4644

4745
def get_columns(

0 commit comments

Comments
 (0)