home-assistant/core
1
0
Fork 1
mirror of https://github.com/home-assistant/core.git synced 2025-08-06 14:15:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

reduce

Browse Source
This commit is contained in:
J. Nick Koston
2023-02-19 16:55:10 -06:00
parent 8353340912
commit 9896867974
1 changed files with 6 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
homeassistant/components/recorder/statistics.py
View File

@@ -16,7 +16,7 @@ import re
from statistics import mean from statistics import mean
from typing import TYPE_CHECKING, Any, Literal, cast from typing import TYPE_CHECKING, Any, Literal, cast
from sqlalchemy import and_, bindparam, func, lambda_stmt, select, text from sqlalchemy import bindparam, func, lambda_stmt, select, text
from sqlalchemy.engine import Engine from sqlalchemy.engine import Engine
from sqlalchemy.engine.row import Row from sqlalchemy.engine.row import Row
from sqlalchemy.exc import OperationalError, SQLAlchemyError, StatementError from sqlalchemy.exc import OperationalError, SQLAlchemyError, StatementError
@@ -2020,21 +2020,11 @@ def _statistics_at_time(
most_recent_statistic_ids = _get_most_recent_statistics_subquery( most_recent_statistic_ids = _get_most_recent_statistics_subquery(
metadata_ids, table, start_time_ts metadata_ids, table, start_time_ts
) )
stmt = lambda_stmt(lambda: columns).where( stmt = lambda_stmt(lambda: columns).join(
table.id
== (
# https://github.com/sqlalchemy/sqlalchemy/issues/9189
# pylint: disable-next=not-callable
select(table.id.label("max_id"))
.join(
most_recent_statistic_ids, most_recent_statistic_ids,
and_( table.start_ts
table.start_ts == most_recent_statistic_ids.c.max_start_ts, == most_recent_statistic_ids.c.max_start_ts & table.metadata_id
table.metadata_id == most_recent_statistic_ids.c.max_metadata_id, == most_recent_statistic_ids.c.max_metadata_id,
),
)
.subquery()
).c.max_id,
) )
return cast(Sequence[Row], execute_stmt_lambda_element(session, stmt)) return cast(Sequence[Row], execute_stmt_lambda_element(session, stmt))