From 839f2009f23636186d912b54dce0af4f0d4c90b5 Mon Sep 17 00:00:00 2001
From: Kenneth Kehl <@kkehl@flexion.us>
Date: Fri, 25 Jul 2025 07:35:39 -0700
Subject: [PATCH 1/2] clear up sqlalchemy warning

---
 app/dao/inbound_sms_dao.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/app/dao/inbound_sms_dao.py b/app/dao/inbound_sms_dao.py
index c54cf8c33..32e91cd79 100644
--- a/app/dao/inbound_sms_dao.py
+++ b/app/dao/inbound_sms_dao.py
@@ -119,7 +119,6 @@ def _delete_inbound_sms(datetime_to_delete_from, query_filter):
         select(InboundSms.id)
         .where(InboundSms.created_at < datetime_to_delete_from, *query_filter)
         .limit(query_limit)
-        .subquery()
     )
 
     deleted = 0

From dd42b9636c64365968d9cd8854b48c99e9abe539 Mon Sep 17 00:00:00 2001
From: Kenneth Kehl <@kkehl@flexion.us>
Date: Fri, 25 Jul 2025 08:00:43 -0700
Subject: [PATCH 2/2] fix

---
 app/dao/inbound_sms_dao.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/app/dao/inbound_sms_dao.py b/app/dao/inbound_sms_dao.py
index 32e91cd79..ae2e586ce 100644
--- a/app/dao/inbound_sms_dao.py
+++ b/app/dao/inbound_sms_dao.py
@@ -119,6 +119,7 @@ def _delete_inbound_sms(datetime_to_delete_from, query_filter):
         select(InboundSms.id)
         .where(InboundSms.created_at < datetime_to_delete_from, *query_filter)
         .limit(query_limit)
+        .subquery()
     )
 
     deleted = 0
@@ -127,7 +128,7 @@ def _delete_inbound_sms(datetime_to_delete_from, query_filter):
     while number_deleted > 0:
         _insert_inbound_sms_history(subquery, query_limit=query_limit)
 
-        stmt = delete(InboundSms).where(InboundSms.id.in_(subquery))
+        stmt = delete(InboundSms).where(InboundSms.id.in_(select(subquery.c.id)))
         number_deleted = db.session.execute(stmt).rowcount
         db.session.commit()
         deleted += number_deleted