This is an automated email from the ASF dual-hosted git repository. dheres pushed a commit to branch pub_task_launcher in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git
commit 8f7366f8271748edc5e725bcb765cd3567c420aa Author: Daniël Heres <[email protected]> AuthorDate: Thu Mar 2 13:19:48 2023 +0100 Make task launcher pub --- ballista/scheduler/src/scheduler_server/mod.rs | 2 +- ballista/scheduler/src/state/task_manager.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ballista/scheduler/src/scheduler_server/mod.rs b/ballista/scheduler/src/scheduler_server/mod.rs index d31d5031..69a8c1b4 100644 --- a/ballista/scheduler/src/scheduler_server/mod.rs +++ b/ballista/scheduler/src/scheduler_server/mod.rs @@ -105,7 +105,7 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan> SchedulerServer<T } #[allow(dead_code)] - pub(crate) fn new_with_task_launcher( + pub fn new_with_task_launcher( scheduler_name: String, cluster: BallistaCluster, codec: BallistaCodec<T, U>, diff --git a/ballista/scheduler/src/state/task_manager.rs b/ballista/scheduler/src/state/task_manager.rs index e1ed21e4..00532962 100644 --- a/ballista/scheduler/src/state/task_manager.rs +++ b/ballista/scheduler/src/state/task_manager.rs @@ -58,7 +58,7 @@ pub const TASK_MAX_FAILURES: usize = 4; pub const STAGE_MAX_FAILURES: usize = 4; #[async_trait::async_trait] -pub(crate) trait TaskLauncher: Send + Sync + 'static { +pub trait TaskLauncher: Send + Sync + 'static { async fn launch_tasks( &self, executor: &ExecutorMetadata,
