Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ballista/rust/client/src/context.rs
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ impl BallistaContextState {

log::info!("Running in local mode. Scheduler will be run in-proc");

let addr = ballista_scheduler::new_standalone_scheduler().await?;
let addr = ballista_scheduler::standalone::new_standalone_scheduler().await?;

let scheduler = loop {
match SchedulerGrpcClient::connect(format!(
Expand Down
4 changes: 2 additions & 2 deletions ballista/rust/scheduler/scheduler_config_spec.toml
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,9 @@ doc = "Print version of this executable"
[[param]]
abbr = "b"
name = "config_backend"
type = "ballista_scheduler::ConfigBackend"
type = "ballista_scheduler::state::ConfigBackend"
doc = "The configuration backend for the scheduler, see ConfigBackend::variants() for options. Default: Standalone"
default = "ballista_scheduler::ConfigBackend::Standalone"
default = "ballista_scheduler::state::ConfigBackend::Standalone"

[[param]]
abbr = "n"
Expand Down
2 changes: 1 addition & 1 deletion ballista/rust/scheduler/src/api/handlers.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
// See the License for the specific language governing permissions and
// limitations under the License.

use crate::SchedulerServer;
use crate::scheduler_server::SchedulerServer;
use ballista_core::serde::{AsExecutionPlan, AsLogicalPlan};
use ballista_core::BALLISTA_VERSION;
use warp::Rejection;
Expand Down
2 changes: 1 addition & 1 deletion ballista/rust/scheduler/src/api/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@

mod handlers;

use crate::SchedulerServer;
use crate::scheduler_server::SchedulerServer;
use anyhow::Result;
use ballista_core::serde::{AsExecutionPlan, AsLogicalPlan};
use std::{
Expand Down
Loading