Fix condition

Signed-off-by: Cheng Su <[email protected]>
ray-project · Apr 15, 2024 · bb5103d · bb5103d
1 parent 01b30fb
commit bb5103d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/python/ray/data/_internal/execution/streaming_executor_state.py b/python/ray/data/_internal/execution/streaming_executor_state.py
@@ -198,8 +198,8 @@ def initialize_progress_bars(self, index: int, verbose_progress: bool) -> int:
  """
  is_all_to_all = isinstance(self.op, AllToAllOperator)
  # Only show 1:1 ops when in verbose progress mode.
- enabled = DataContext.get_current().enable_progress_bars and (
- verbose_progress or is_all_to_all
+ enabled = is_all_to_all or (
+ DataContext.get_current().enable_progress_bars and verbose_progress
  )
  self.progress_bar = ProgressBar(
  "- " + self.op.name,