Bugfix/idle transactions

src/dispatch/cli.py

@@ -763,6 +763,7 @@ def run_slack_websocket(organization: str, project: str):
         )
         return
 
+    session.close()
     click.secho("Slack websocket process started...", fg="blue")
     asyncio.run(socket_mode.run_websocket_process(instance.configuration))
 

src/dispatch/plugins/dispatch_slack/actions.py

@@ -188,6 +188,8 @@ def handle_dialog_action(
             action=action,
         )
 
+    db_session.close()
+
 
 def handle_block_action(
     config: SlackConversationConfiguration, action: dict, background_tasks: BackgroundTasks

src/dispatch/plugins/dispatch_slack/commands.py

@@ -241,6 +241,8 @@ async def handle_incident_conversation_commands(config, client, request, backgro
             command=request,
         )
 
+    db_session.close()
+
     return get_incident_conversation_command_message(config, command)
 
 

src/dispatch/plugins/dispatch_slack/events.py

@@ -143,6 +143,8 @@ async def handle_slack_event(*, config, client, event, background_tasks):
                     event=event,
                 )
 
+        db_session.close()
+
     return {"ok": ""}
 
 

src/dispatch/plugins/dispatch_slack/menus.py

@@ -11,7 +11,10 @@
 from dispatch.plugins.dispatch_slack.modals.common import parse_submitted_form
 from dispatch.plugins.dispatch_slack.modals.incident.enums import IncidentBlockId
 
-from .decorators import get_organization_scope_from_channel_id, get_organization_scope_from_slug
+from .decorators import (
+    get_organization_scope_from_channel_id,
+    get_organization_scope_from_slug,
+)
 
 log = logging.getLogger(__name__)
 
@@ -39,7 +42,9 @@ async def handle_slack_menu(*, config, client: WebClient, request: Request, orga
         db_session = get_organization_scope_from_slug(organization)
 
     f = menu_functions(action_id)
-    return f(db_session, user_id, user_email, channel_id, incident_id, query_str, request)
+    menu = f(db_session, user_id, user_email, channel_id, incident_id, query_str, request)
+    db_session.close()
+    return menu
 
 
 def menu_functions(action_id: str):

src/dispatch/plugins/dispatch_slack/views.py

@@ -70,8 +70,9 @@ def verify_signature(organization: str, request_data: str, timestamp: int, signa
         h = hmac.new(slack_signing_secret, req, hashlib.sha256).hexdigest()
         result = hmac.compare_digest(f"v0={h}", signature)
         if result:
+            session.close()
             return p.instance.configuration
-
+    session.close()
     raise HTTPException(status_code=403, detail=[{"msg": "Invalid request signature"}])