add a flush

2026-03-02 22:25:47 +00:00 · 2025-03-26 12:02:44 -07:00
1 changed files with 2 additions and 0 deletions
--- a/backend/onyx/background/celery/tasks/connector_deletion/tasks.py
+++ b/backend/onyx/background/celery/tasks/connector_deletion/tasks.py
@@ -451,6 +451,8 @@ def monitor_connector_deletion_taskset(
                credential_id=cc_pair.credential_id,
            )

+            db_session.flush()
+
            # finally, delete the cc-pair
            delete_connector_credential_pair__no_commit(
                db_session=db_session,