Skip to content

Commit

Permalink
Remove namespace from executors
Browse files Browse the repository at this point in the history
  • Loading branch information
edrevo committed Apr 26, 2021
1 parent 35bc3d7 commit 5016ea4
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 10 deletions.
7 changes: 0 additions & 7 deletions ballista/rust/executor/executor_config_spec.toml
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,6 @@ conf_file_param = "config_file"
name = "version"
doc = "Print version of this executable"

[[param]]
abbr = "n"
name = "namespace"
type = "String"
doc = "Namespace for the ballista cluster that this executor will join. yippee"
default = "std::string::String::from(\"ballista\")"

[[param]]
name = "scheduler_host"
type = "String"
Expand Down
7 changes: 4 additions & 3 deletions ballista/rust/executor/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,6 @@ async fn main() -> Result<()> {
std::process::exit(0);
}

let namespace = opt.namespace;
let external_host = opt.external_host;
let bind_host = opt.bind_host;
let port = opt.port;
Expand Down Expand Up @@ -109,8 +108,10 @@ async fn main() -> Result<()> {
info!("Running in local mode. Scheduler will be run in-proc");
let client = StandaloneClient::try_new_temporary()
.context("Could not create standalone config backend")?;
let server =
SchedulerGrpcServer::new(SchedulerServer::new(Arc::new(client), namespace));
let server = SchedulerGrpcServer::new(SchedulerServer::new(
Arc::new(client),
"ballista".to_string(),
));
let addr = format!("{}:{}", bind_host, scheduler_port);
let addr = addr
.parse()
Expand Down

0 comments on commit 5016ea4

Please sign in to comment.