This is an automated email from the ASF dual-hosted git repository.
dheres pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-ballista.git
The following commit(s) were added to refs/heads/main by this push:
new 565088f4 Make task launcher pub (#695)
565088f4 is described below
commit 565088f43796c80b4233d2418d13db2888b5b609
Author: Daniël Heres <[email protected]>
AuthorDate: Thu Mar 2 14:08:29 2023 +0100
Make task launcher pub (#695)
Co-authored-by: Daniël Heres <[email protected]>
---
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,