We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8e1798a commit 0b911d4Copy full SHA for 0b911d4
compiler/base/orchestrator/src/worker.rs
@@ -463,18 +463,18 @@ impl ProcessState {
463
self.processes.spawn({
464
let stdin_shutdown_tx = self.stdin_shutdown_tx.clone();
465
async move {
466
+ let message = process_end(
467
+ token,
468
+ child,
469
+ task_set,
470
+ statistics_task,
471
+ stdin_shutdown_tx,
472
+ job_id,
473
+ )
474
+ .await;
475
+
476
worker_msg_tx
- .send(
- process_end(
- token,
- child,
- task_set,
- statistics_task,
- stdin_shutdown_tx,
- job_id,
- )
- .await,
477
+ .send(message)
478
.await
479
.context(UnableToSendExecuteCommandResponseSnafu)
480
}
0 commit comments