Fix semaphore

Author: k-raina

tests/ducktape/benchmark_metrics.py

@@ -268,16 +268,14 @@ def _load_from_config_file(self, config_path: str):
                 config = json.load(f)
 
             # Always use environment-based format
-            environment = os.getenv('BENCHMARK_ENVIRONMENT', 
-                                   config.get('_default_environment', 'local'))
-            
+            environment = os.getenv('BENCHMARK_ENVIRONMENT',
+                                    config.get('_default_environment', 'local'))
             if environment not in config:
                 available_envs = [k for k in config.keys() if not k.startswith('_')]
                 raise ValueError(
                     f"Environment '{environment}' not found in config. "
                     f"Available environments: {available_envs}"
                 )
-            
             bounds_config = config[environment]
             print(f"Loading benchmark bounds for environment: {environment}")
 

tests/ducktape/run_ducktape_test.py

@@ -43,7 +43,7 @@ def main():
             import pkg_resources
             version = pkg_resources.get_distribution('ducktape').version
             print(f"Using ducktape version: {version}")
-        except:
+        except Exception:
             print("Using ducktape version: unknown")
 
     # Check if confluent_kafka is available

tests/ducktape/test_producer.py

@@ -373,7 +373,8 @@ def delivery_callback(err, msg):
         if not is_valid:
             self.logger.error("Performance bounds validation failed for %s compression: %s",
                               compression_type, "; ".join(violations))
-            assert False, f"Performance bounds validation failed for {compression_type} compression: {'; '.join(violations)}"
+            assert False, (f"Performance bounds validation failed for {compression_type} "
+                           f"compression: {'; '.join(violations)}")
 
         self.logger.info("Successfully completed %s compression test with comprehensive metrics", compression_type)