[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

src/workflows/recipe/__init__.py

@@ -101,7 +101,7 @@ def unwrap_recipe(header, message):
 
                 if recipe_id:
                     log_extra["recipe_id"] = recipe_id
-        
+
             if log_extender and rw.environment and rw.environment.get("ID"):
                 with log_extender("recipe_ID", rw.environment["ID"]):
                     return callback(rw, header, message.get("payload"))

src/workflows/services/common_service.py

@@ -192,15 +192,19 @@ def start_transport(self):
             self.transport.subscription_callback_set_intercept(
                 self._transport_interceptor
             )
-            
+
             # Configure OTELTracing if configuration is available
-            otel_config = OTEL.config if hasattr(OTEL, 'config') and OTEL.config else None
-            
+            otel_config = (
+                OTEL.config if hasattr(OTEL, "config") and OTEL.config else None
+            )
+
             if otel_config:
                 # Configure OTELTracing
-                resource = Resource.create({
-                    SERVICE_NAME: self._service_name,
-                })
+                resource = Resource.create(
+                    {
+                        SERVICE_NAME: self._service_name,
+                    }
+                )
 
                 self.log.debug("Configuring OTELTracing")
                 provider = TracerProvider(resource=resource)
@@ -209,7 +213,7 @@ def start_transport(self):
                 # Configure BatchProcessor and OTLPSpanExporter using config values
                 otlp_exporter = OTLPSpanExporter(
                     endpoint=otel_config["endpoint"],
-                    timeout=otel_config.get("timeout", 10)
+                    timeout=otel_config.get("timeout", 10),
                 )
             span_processor = BatchSpanProcessor(otlp_exporter)
             provider.add_span_processor(span_processor)
@@ -221,7 +225,6 @@ def start_transport(self):
             )
             self._transport.add_middleware(otel_middleware)
 
-
             metrics = self._environment.get("metrics")
             if metrics:
                 import prometheus_client

src/workflows/util/zocalo/configuration.py

@@ -7,6 +7,7 @@
 from workflows.transport.pika_transport import PikaTransport
 from workflows.transport.stomp_transport import StompTransport
 
+
 class OTEL:
     """A Zocalo configuration plugin to pre-populate OTELTracing config defaults"""
 
@@ -23,10 +24,12 @@ class Schema(PluginSchema):
     def activate(configuration):
         # Build the full endpoint URL if not provided
         if "endpoint" not in configuration:
-            endpoint = f"https://{configuration['host']}:{configuration['port']}/v1/traces"
+            endpoint = (
+                f"https://{configuration['host']}:{configuration['port']}/v1/traces"
+            )
         else:
             endpoint = configuration["endpoint"]
-        
+
         OTEL.config["endpoint"] = endpoint
         OTEL.config["timeout"] = configuration.get("timeout", 10)