Fixed exec_err! message (#388)

sandugood · web-flow · commit 0f2c8be3e148 · 2026-03-24T18:33:29.000+01:00
diff --git a/src/networking/worker_resolver.rs b/src/networking/worker_resolver.rs
@@ -44,7 +44,7 @@ pub fn get_distributed_worker_resolver(
 ) -> Result<Arc<dyn WorkerResolver + Send + Sync>, DataFusionError> {
     let opts = cfg.options();
     let Some(distributed_cfg) = opts.extensions.get::<DistributedConfig>() else {
-        return exec_err!("ChannelResolver not present in the session config");
+        return exec_err!("WorkerResolver not present in the session config");
     };
     Ok(Arc::clone(&distributed_cfg.__private_worker_resolver.0))
 }

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ pub fn get_distributed_worker_resolver(`
`44`	`44`	`) -> Result<Arc<dyn WorkerResolver + Send + Sync>, DataFusionError> {`
`45`	`45`	`let opts = cfg.options();`
`46`	`46`	`let Some(distributed_cfg) = opts.extensions.get::<DistributedConfig>() else {`
`47`		`- return exec_err!("ChannelResolver not present in the session config");`
	`47`	`+ return exec_err!("WorkerResolver not present in the session config");`
`48`	`48`	`};`
`49`	`49`	`Ok(Arc::clone(&distributed_cfg.__private_worker_resolver.0))`
`50`	`50`	`}`