Commit 9f1ee81 1 parent b62b9d9 commit 9f1ee81 Copy full SHA for 9f1ee81
File tree 1 file changed +9
-4
lines changed
data_studio_jupyter_extensions/configurables
1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -110,8 +110,9 @@ async def poll(self):
110
110
km = self .kernel_manager
111
111
112
112
if self .is_culling_enabled ():
113
- await self .cull_if_idle ()
114
- return
113
+ culled = await self .cull_if_idle ()
114
+ if culled :
115
+ return
115
116
116
117
# If the kernel is communicating, we're good here.
117
118
if km .is_communicating ():
@@ -160,7 +161,7 @@ def is_culling_enabled(self) -> bool:
160
161
"""
161
162
return self .cull_idle_timeout > 0
162
163
163
- async def cull_if_idle (self ):
164
+ async def cull_if_idle (self ) -> bool :
164
165
"""Cull kernel if inactive."""
165
166
km = self .kernel_manager
166
167
dt_now = utcnow ()
@@ -181,5 +182,9 @@ async def cull_if_idle(self):
181
182
)
182
183
# self._emit_console("Culling", msg) ## TODO: relay culled msg to user
183
184
self .log .info (msg )
185
+ await km .shutdown_kernel ()
186
+ self ._fire_callbacks ("dead" )
184
187
self .stop ()
185
- await km .shutdown_kernel () ## TODO: clear sessionInfo for this kernel
188
+ return True
189
+ else :
190
+ return False
You can’t perform that action at this time.
0 commit comments