[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

@@ -71,7 +71,6 @@ def unwrap_recipe(header, message):
         if mangle_for_receiving:
             message = mangle_for_receiving(message)
         if header.get("workflows-recipe") in {True, "True", "true", 1}:
-            
             rw = RecipeWrapper(message=message, transport=transport_layer)
 
             if log_extender and rw.environment["ID"]:
@@ -90,15 +89,12 @@ def unwrap_recipe(header, message):
                     otel_logs = {
                         "span_id": span_id,
                         "trace_id": trace_id,
-                        "recipe_id": recipe_id
+                        "recipe_id": recipe_id,
                     }
 
                 with ExitStack() as stack:
-                    
                     # Configure the context depending on if service is emitting spans
-                    stack.enter_context(
-                        log_extender("recipe_ID", recipe_id)
-                    )
+                    stack.enter_context(log_extender("recipe_ID", recipe_id))
                     if otel_logs:
                         stack.enter_context(log_extender("otel_logs", otel_logs))
                     return callback(rw, header, message.get("payload"))

src/workflows/transport/middleware/__init__.py

@@ -233,7 +233,6 @@ def wrapped_callback(header, message):
 
 
 def wrap(f: Callable):
-
     @functools.wraps(f)
     def wrapper(self, *args, **kwargs):
         return functools.reduce(

src/workflows/transport/middleware/otel_tracing.py

@@ -1,14 +1,15 @@
 from __future__ import annotations
 
 import functools
-import json
 from collections.abc import Callable
 
 from opentelemetry import trace
 from opentelemetry.context import Context
 from opentelemetry.propagate import extract, inject
 
 from workflows.transport.common_transport import MessageCallback, TemporarySubscription
+
+
 class OTELTracingMiddleware:
     def __init__(self, tracer: trace.Tracer, service_name: str):
         self.tracer = tracer