Fix logic for purge of recorder runs

2024-11-11 17:41:24 +01:00
3 changed files with 3 additions and 3 deletions
--- a/homeassistant/components/recorder/queries.py
+++ b/homeassistant/components/recorder/queries.py
@ -608,7 +608,7 @@ def delete_recorder_runs_rows(
    """Delete recorder_runs rows."""
    return lambda_stmt(
        lambda: delete(RecorderRuns)
-        .filter(RecorderRuns.start < purge_before)
+        .filter(RecorderRuns.end < purge_before)
        .filter(RecorderRuns.run_id != current_run_id)
        .execution_options(synchronize_session=False)
    )
--- a/tests/components/recorder/test_purge.py
+++ b/tests/components/recorder/test_purge.py
@ -376,7 +376,7 @@ async def test_purge_old_recorder_runs(

    with session_scope(hass=hass) as session:
        recorder_runs = session.query(RecorderRuns)
-        assert recorder_runs.count() == 1
+        assert recorder_runs.count() == 3


 async def test_purge_old_statistics_runs(
--- a/tests/components/recorder/test_purge_v32_schema.py
+++ b/tests/components/recorder/test_purge_v32_schema.py
@ -347,7 +347,7 @@ async def test_purge_old_recorder_runs(

    with session_scope(hass=hass) as session:
        recorder_runs = session.query(RecorderRuns)
-        assert recorder_runs.count() == 1
+        assert recorder_runs.count() == 3


 async def test_purge_old_statistics_runs(