remove debug from scheduler config

milenkovicm · Dec 9, 2024 · 466b0fe · 466b0fe
1 parent 42e5440
commit 466b0fe
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 55 deletions.
diff --git a/ballista/scheduler/src/config.rs b/ballista/scheduler/src/config.rs
@@ -83,57 +83,6 @@ pub struct SchedulerConfig {
     pub override_physical_codec: Option<Arc<dyn PhysicalExtensionCodec>>,
 }
 
-impl std::fmt::Debug for SchedulerConfig {
-    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
-        f.debug_struct("SchedulerConfig")
-            .field("namespace", &self.namespace)
-            .field("external_host", &self.external_host)
-            .field("bind_port", &self.bind_port)
-            .field("bind_host", &self.bind_host)
-            .field("scheduling_policy", &self.scheduling_policy)
-            .field("event_loop_buffer_size", &self.event_loop_buffer_size)
-            .field("task_distribution", &self.task_distribution)
-            .field(
-                "finished_job_data_clean_up_interval_seconds",
-                &self.finished_job_data_clean_up_interval_seconds,
-            )
-            .field(
-                "finished_job_state_clean_up_interval_seconds",
-                &self.finished_job_state_clean_up_interval_seconds,
-            )
-            .field(
-                "advertise_flight_sql_endpoint",
-                &self.advertise_flight_sql_endpoint,
-            )
-            .field("job_resubmit_interval_ms", &self.job_resubmit_interval_ms)
-            .field("cluster_storage", &self.cluster_storage)
-            .field(
-                "executor_termination_grace_period",
-                &self.executor_termination_grace_period,
-            )
-            .field(
-                "scheduler_event_expected_processing_duration",
-                &self.scheduler_event_expected_processing_duration,
-            )
-            .field(
-                "grpc_server_max_decoding_message_size",
-                &self.grpc_server_max_decoding_message_size,
-            )
-            .field(
-                "grpc_server_max_encoding_message_size",
-                &self.grpc_server_max_encoding_message_size,
-            )
-            .field("executor_timeout_seconds", &self.executor_timeout_seconds)
-            .field(
-                "expire_dead_executor_interval_seconds",
-                &self.expire_dead_executor_interval_seconds,
-            )
-            .field("override_logical_codec", &self.override_logical_codec)
-            .field("override_physical_codec", &self.override_physical_codec)
-            .finish()
-    }
-}
-
 impl Default for SchedulerConfig {
     fn default() -> Self {
         Self {

diff --git a/python/src/cluster.rs b/python/src/cluster.rs
@@ -128,8 +128,9 @@ impl PyScheduler {
 
     pub fn __repr__(&self) -> String {
         format!(
-            "BallistaScheduler(config={:?}, listening= {})",
-            self.config,
+            "BallistaScheduler(listening address={}:{}, listening= {})",
+            self.config.bind_host,
+            self.config.bind_port,
             self.handle.is_some()
         )
     }
@@ -246,18 +247,19 @@ impl PyExecutor {
                 self.config.bind_host,
                 self.config.port,
                 self.config.scheduler_host,
-                self.config.scheduler_port
+                self.config.scheduler_port,
             ),
         }
     }
 
     pub fn __repr__(&self) -> String {
         format!(
-            "BallistaExecutor(address={}:{}, scheduler={}:{}, listening={})",
+            "BallistaExecutor(address={}:{}, scheduler={}:{}, concurrent_tasks={} listening={})",
             self.config.bind_host,
             self.config.port,
             self.config.scheduler_host,
             self.config.scheduler_port,
+            self.config.concurrent_tasks,
             self.handle.is_some()
         )
     }