summaryrefslogtreecommitdiff
path: root/cli/ops/jupyter.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/ops/jupyter.rs')
-rw-r--r--cli/ops/jupyter.rs18
1 files changed, 8 insertions, 10 deletions
diff --git a/cli/ops/jupyter.rs b/cli/ops/jupyter.rs
index 95d232f11..f7f006d9b 100644
--- a/cli/ops/jupyter.rs
+++ b/cli/ops/jupyter.rs
@@ -65,14 +65,12 @@ pub fn op_jupyter_input(
return Ok(None);
}
- let msg = JupyterMessage::new(
- InputRequest {
- prompt,
- password: is_password,
- }
- .into(),
- Some(&last_request),
- );
+ let content = InputRequest {
+ prompt,
+ password: is_password,
+ };
+
+ let msg = JupyterMessage::new(content, Some(&last_request));
let Ok(()) = stdin_connection_proxy.lock().tx.send(msg) else {
return Ok(None);
@@ -149,13 +147,13 @@ pub fn op_print(
let sender = state.borrow_mut::<mpsc::UnboundedSender<StreamContent>>();
if is_err {
- if let Err(err) = sender.send(StreamContent::stderr(msg.into())) {
+ if let Err(err) = sender.send(StreamContent::stderr(msg)) {
log::error!("Failed to send stderr message: {}", err);
}
return Ok(());
}
- if let Err(err) = sender.send(StreamContent::stdout(msg.into())) {
+ if let Err(err) = sender.send(StreamContent::stdout(msg)) {
log::error!("Failed to send stdout message: {}", err);
}
Ok(())