This is an automated email from the ASF dual-hosted git repository.
andygrove pushed a commit to branch branch-54
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git
The following commit(s) were added to refs/heads/branch-54 by this push:
new c2d329945 Fixed: notify_shutdown sending signal before drop (#2107)
(#2237)
c2d329945 is described below
commit c2d329945117edc8c8bc43f38a9898c2e2e13a2b
Author: Andy Grove <[email protected]>
AuthorDate: Thu Aug 6 07:53:18 2026 -0600
Fixed: notify_shutdown sending signal before drop (#2107) (#2237)
(cherry picked from commit c77e48127f82725f1428e0a91d645d771c7364b9)
Co-authored-by: alexander domenti
<[email protected]>
---
ballista/executor/src/executor_process.rs | 1 +
1 file changed, 1 insertion(+)
diff --git a/ballista/executor/src/executor_process.rs
b/ballista/executor/src/executor_process.rs
index 360a89491..99df368b4 100644
--- a/ballista/executor/src/executor_process.rs
+++ b/ballista/executor/src/executor_process.rs
@@ -647,6 +647,7 @@ pub async fn start_executor_process(
// When `notify_shutdown` is dropped, all components which have
`subscribe`d will
// receive the shutdown signal and can exit
+ let _ = notify_shutdown.send(());
drop(notify_shutdown);
// Drop final `Sender` so the `Receiver` below can complete
drop(shutdown_complete_tx);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
