This is an automated email from the ASF dual-hosted git repository.
andygrove 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 b673bd496 fix(ci): apply cargo fmt to chaos-executor (#2304)
b673bd496 is described below
commit b673bd4966867c4a3d92297abc51e9e43c8f8b1f
Author: Andy Grove <[email protected]>
AuthorDate: Sat Aug 15 09:30:49 2026 -0700
fix(ci): apply cargo fmt to chaos-executor (#2304)
cargo fmt --all -- --check fails on main as of #2244, which fails the
Lint job on every open pull request.
---
chaos-testing/src/bin/chaos-executor.rs | 24 +++++++++++++-----------
1 file changed, 13 insertions(+), 11 deletions(-)
diff --git a/chaos-testing/src/bin/chaos-executor.rs
b/chaos-testing/src/bin/chaos-executor.rs
index 820eb48bc..f8d3a765d 100644
--- a/chaos-testing/src/bin/chaos-executor.rs
+++ b/chaos-testing/src/bin/chaos-executor.rs
@@ -74,17 +74,19 @@ async fn main() -> ballista_core::error::Result<()> {
// liveness; `/readyz` reflects heartbeat state. Only started when
// `CHAOS_EXECUTOR_HEALTH_PORT` is set (the k8s manifest sets it), so the
// process-based `TestCluster` harness spawns no extra server.
- let health_server =
std::env::var("CHAOS_EXECUTOR_HEALTH_PORT").ok().map(|port| {
- let port: u16 = port
- .parse()
- .unwrap_or_else(|e| panic!("CHAOS_EXECUTOR_HEALTH_PORT must be a
u16: {e}"));
- let addr: SocketAddr = format!("{}:{}", config.bind_host, port)
- .parse()
- .expect("health server address must parse");
- let (shutdown_tx, shutdown_rx) = tokio::sync::oneshot::channel();
- let handle = spawn_health_server(addr, config.health.clone(),
shutdown_rx);
- (shutdown_tx, handle)
- });
+ let health_server = std::env::var("CHAOS_EXECUTOR_HEALTH_PORT")
+ .ok()
+ .map(|port| {
+ let port: u16 = port.parse().unwrap_or_else(|e| {
+ panic!("CHAOS_EXECUTOR_HEALTH_PORT must be a u16: {e}")
+ });
+ let addr: SocketAddr = format!("{}:{}", config.bind_host, port)
+ .parse()
+ .expect("health server address must parse");
+ let (shutdown_tx, shutdown_rx) = tokio::sync::oneshot::channel();
+ let handle = spawn_health_server(addr, config.health.clone(),
shutdown_rx);
+ (shutdown_tx, handle)
+ });
let result = start_executor_process(Arc::new(config)).await;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
