one line

packages/phoenix-evals/src/phoenix/evals/executors.py

@@ -225,10 +225,11 @@ def termination_handler(signum: int, frame: Any) -> None:
         original_handler = signal.signal(self.termination_signal, termination_handler)
         outputs = [self.fallback_return_value] * len(inputs)
         execution_details = [ExecutionDetails() for _ in range(len(inputs))]
-        if self.tqdm_bar_format is None:
-            progress_bar = tqdm(total=len(inputs), bar_format=self.tqdm_bar_format, disable=True)
-        else:
-            progress_bar = tqdm(total=len(inputs), bar_format=self.tqdm_bar_format)
+        progress_bar = tqdm(
+            total=len(inputs),
+            bar_format=self.tqdm_bar_format,
+            disable=self.tqdm_bar_format is None,
+        )
 
         max_queue_size = 5 * self.concurrency  # limit the queue to bound memory usage
         max_fill = max_queue_size - (2 * self.concurrency)  # ensure there is always room to requeue
@@ -342,10 +343,11 @@ def run(self, inputs: Sequence[Any]) -> Tuple[List[Any], List[Any]]:
             execution_details: List[ExecutionDetails] = [
                 ExecutionDetails() for _ in range(len(inputs))
             ]
-            if self.tqdm_bar_format is None:
-                progress_bar = tqdm(total=len(inputs), bar_format=self.tqdm_bar_format, disable=True)
-            else:
-                progress_bar = tqdm(total=len(inputs), bar_format=self.tqdm_bar_format)
+            progress_bar = tqdm(
+                total=len(inputs),
+                bar_format=self.tqdm_bar_format,
+                disable=self.tqdm_bar_format is None,
+            )
 
             for index, input in enumerate(inputs):
                 task_start_time = time.time()