This is an automated email from the ASF dual-hosted git repository.
milenkovicm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new c77e48127 Fixed: notify_shutdown sending signal before drop (#2107)
c77e48127 is described below
commit c77e48127f82725f1428e0a91d645d771c7364b9
Author: alexander domenti <[email protected]>
AuthorDate: Mon Jul 20 22:26:57 2026 +0300
Fixed: notify_shutdown sending signal before drop (#2107)
---
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 d8f30163b..a48216132 100644
--- a/ballista/executor/src/executor_process.rs
+++ b/ballista/executor/src/executor_process.rs
@@ -670,6 +670,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]
