11
11
from kernel_sidecar .models import messages
12
12
from kernel_sidecar .models .messages import CellStatus , StreamChannel
13
13
14
- from notebookgpt .models import (
14
+ from jupychat .models import (
15
15
CreateKernelRequest ,
16
16
CreateKernelResponse ,
17
17
DisplayData ,
18
18
RunCellRequest ,
19
19
RunCellResponse ,
20
20
image_store ,
21
21
)
22
- from notebookgpt .settings import get_settings
22
+ from jupychat .settings import get_settings
23
23
24
24
logger = structlog .get_logger (__name__ )
25
25
@@ -31,7 +31,7 @@ def safe_get_ipython():
31
31
return InteractiveShellEmbed ()
32
32
33
33
34
- class NotebookGPTKernelClient :
34
+ class JupyChatKernelClient :
35
35
"""Client class for managing jupyter kernels.
36
36
37
37
This wraps the jupyter multi kernel manager and provides a simple
@@ -52,7 +52,7 @@ async def start_kernel(self, request: CreateKernelRequest) -> CreateKernelRespon
52
52
53
53
async def run_cell (self , request : RunCellRequest ) -> RunCellResponse :
54
54
sidecar_client = self ._sidecar_clients [request .kernel_id ]
55
- output_handler = NotebookGPTOutputHandler (sidecar_client , uuid .uuid4 ().hex )
55
+ output_handler = JupyChatOutputHandler (sidecar_client , uuid .uuid4 ().hex )
56
56
status_handler = StatusHandler ()
57
57
await sidecar_client .execute_request (
58
58
request .code , handlers = [output_handler , status_handler ]
@@ -66,7 +66,7 @@ async def shutdown_all(self) -> None:
66
66
logger .info ("Shut down kernel" , kernel_id = kernel_id )
67
67
68
68
69
- class NotebookGPTOutputHandler (OutputHandler ):
69
+ class JupyChatOutputHandler (OutputHandler ):
70
70
def __init__ (self , client : KernelSidecarClient , cell_id : str ):
71
71
super ().__init__ (client , cell_id )
72
72
@@ -125,7 +125,7 @@ async def handle_execute_reply(self, msg: messages.ExecuteReply) -> None:
125
125
126
126
127
127
@lru_cache (maxsize = 1 )
128
- def get_nb_gpt_kernel_client () -> NotebookGPTKernelClient :
128
+ def get_nb_gpt_kernel_client () -> JupyChatKernelClient :
129
129
settings = get_settings ()
130
130
mkm = AsyncMultiKernelManager (connection_dir = settings .jupyter_connection_dir )
131
- return NotebookGPTKernelClient (mkm )
131
+ return JupyChatKernelClient (mkm )
0 commit comments