Skip to content

Commit a38167b

Browse files
Carreaupre-commit-ci[bot]blink1073
authored
Configurables needs to be configurable (#1037)
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com> Co-authored-by: Steven Silvester <[email protected]>
1 parent e7aecf5 commit a38167b

File tree

2 files changed

+22
-5
lines changed

2 files changed

+22
-5
lines changed

ipykernel/ipkernel.py

Lines changed: 20 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,10 +12,20 @@
1212
import comm
1313
from IPython.core import release
1414
from IPython.utils.tokenutil import line_at_cursor, token_at_cursor
15-
from traitlets import Any, Bool, Instance, List, Type, observe, observe_compat
15+
from traitlets import (
16+
Any,
17+
Bool,
18+
HasTraits,
19+
Instance,
20+
List,
21+
Type,
22+
observe,
23+
observe_compat,
24+
)
1625
from zmq.eventloop.zmqstream import ZMQStream
1726

1827
from .comm.comm import BaseComm
28+
from .comm.manager import CommManager
1929
from .compiler import XCachingCompiler
2030
from .debugger import Debugger, _is_debugpy_available
2131
from .eventloops import _use_appnope
@@ -40,12 +50,18 @@
4050
_EXPERIMENTAL_KEY_NAME = "_jupyter_types_experimental"
4151

4252

43-
def create_comm(*args, **kwargs):
53+
def _create_comm(*args, **kwargs):
4454
"""Create a new Comm."""
4555
return BaseComm(*args, **kwargs)
4656

4757

48-
comm.create_comm = create_comm
58+
def _get_comm_manager(*args, **kwargs):
59+
"""Create a new CommManager."""
60+
return CommManager(*args, **kwargs)
61+
62+
63+
comm.create_comm = _create_comm
64+
comm.get_comm_manager = _get_comm_manager
4965

5066

5167
class IPythonKernel(KernelBase):
@@ -112,6 +128,7 @@ def __init__(self, **kwargs):
112128

113129
self.comm_manager = comm.get_comm_manager()
114130

131+
assert isinstance(self.comm_manager, HasTraits)
115132
self.shell.configurables.append(self.comm_manager)
116133
comm_msg_types = ["comm_open", "comm_msg", "comm_close"]
117134
for msg_type in comm_msg_types:

ipykernel/tests/test_ipkernel_direct.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import zmq
88
from IPython.core.history import DummyDB
99

10-
from ipykernel.ipkernel import BaseComm, IPythonKernel, create_comm
10+
from ipykernel.ipkernel import BaseComm, IPythonKernel, _create_comm
1111

1212
from .conftest import MockIPyKernel
1313

@@ -187,7 +187,7 @@ async def fake_poll_control_queue():
187187

188188

189189
def test_create_comm():
190-
assert isinstance(create_comm(), BaseComm)
190+
assert isinstance(_create_comm(), BaseComm)
191191

192192

193193
def test_finish_metadata(ipkernel: IPythonKernel):

0 commit comments

Comments
 (0)