Skip to content

Commit

Permalink
Avoid shared channel_queues when they are instance based (#848)
Browse files Browse the repository at this point in the history
  • Loading branch information
CiprianAnton authored May 19, 2022
1 parent 29179e8 commit d376780
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions jupyter_server/gateway/managers.py
Original file line number Diff line number Diff line change
Expand Up @@ -573,8 +573,8 @@ class GatewayKernelClient(AsyncKernelClient):

# flag for whether execute requests should be allowed to call raw_input:
allow_stdin = False
_channels_stopped = False
_channel_queues: Optional[dict] = {}
_channels_stopped: bool
_channel_queues: Optional[dict]
_control_channel: Optional[ChannelQueue]
_hb_channel: Optional[ChannelQueue]
_stdin_channel: Optional[ChannelQueue]
Expand All @@ -586,6 +586,8 @@ def __init__(self, **kwargs):
self.kernel_id = kwargs["kernel_id"]
self.channel_socket: Optional[websocket.WebSocket] = None
self.response_router: Optional[Thread] = None
self._channels_stopped = False
self._channel_queues = {}

# --------------------------------------------------------------------------
# Channel management methods
Expand Down

0 comments on commit d376780

Please sign in to comment.