We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4daac72 commit 6ac6872Copy full SHA for 6ac6872
compiler/base/orchestrator/src/coordinator.rs
@@ -1221,9 +1221,8 @@ impl Container {
1221
} = spawn_io_queue(stdin, stdout, token);
1222
1223
let (command_tx, command_rx) = mpsc::channel(8);
1224
- let demultiplex_task =
1225
- tokio::spawn(Commander::demultiplex(command_rx, from_worker_rx).in_current_span())
1226
- .abort_on_drop();
+ let demultiplex = Commander::demultiplex(command_rx, from_worker_rx);
+ let demultiplex_task = tokio::spawn(demultiplex.in_current_span()).abort_on_drop();
1227
1228
let task = tokio::spawn(
1229
async move {
0 commit comments