@@ -100,15 +100,11 @@ def start(self, function: Callable[..., None], request: BoltRequest) -> None:
100100 )
101101
102102 def wrapped_func ():
103- release_thread_local_connections (
104- request .context .logger , "before-lazy-listener"
105- )
103+ release_thread_local_connections (request .context .logger , "before-lazy-listener" )
106104 try :
107105 func ()
108106 finally :
109- release_thread_local_connections (
110- request .context .logger , "lazy-listener-completion"
111- )
107+ release_thread_local_connections (request .context .logger , "lazy-listener-completion" )
112108
113109 self .executor .submit (wrapped_func )
114110
@@ -124,9 +120,7 @@ def __init__(self, app: App): # type: ignore
124120 )
125121
126122 if not isinstance (listener_runner , ThreadListenerRunner ):
127- raise BoltError (
128- "Custom listener_runners are not compatible with this Django adapter."
129- )
123+ raise BoltError ("Custom listener_runners are not compatible with this Django adapter." )
130124
131125 if app .process_before_response is True :
132126 # As long as the app access Django models in the same thread,
@@ -135,9 +129,7 @@ def __init__(self, app: App): # type: ignore
135129 return
136130
137131 current_start_handler = listener_runner .listener_start_handler
138- if current_start_handler is not None and not isinstance (
139- current_start_handler , DefaultListenerStartHandler
140- ):
132+ if current_start_handler is not None and not isinstance (current_start_handler , DefaultListenerStartHandler ):
141133 # As we run release_thread_local_connections() before listener executions,
142134 # it's okay to skip calling the same connection clean-up method at the listener completion.
143135 message = """As you've already set app.listener_runner.listener_start_handler to your own one,
@@ -152,9 +144,7 @@ def __init__(self, app: App): # type: ignore
152144 self .app .logger .info (message )
153145 else :
154146 # for proper management of thread-local Django DB connections
155- self .app .listener_runner .listener_start_handler = (
156- DjangoListenerStartHandler ()
157- )
147+ self .app .listener_runner .listener_start_handler = DjangoListenerStartHandler ()
158148 self .app .logger .debug ("DjangoListenerStartHandler has been enabled" )
159149
160150 current_completion_handler = listener_runner .listener_completion_handler
@@ -169,9 +159,7 @@ def __init__(self, app: App): # type: ignore
169159 self .app .logger .info (message )
170160 return
171161 # for proper management of thread-local Django DB connections
172- self .app .listener_runner .listener_completion_handler = (
173- DjangoListenerCompletionHandler ()
174- )
162+ self .app .listener_runner .listener_completion_handler = DjangoListenerCompletionHandler ()
175163 self .app .logger .debug ("DjangoListenerCompletionHandler has been enabled" )
176164
177165 def handle (self , req : HttpRequest ) -> HttpResponse :
0 commit comments