Run linter

Signed-off-by: Sergio Herrera <627709+seherv@users.noreply.github.com>

Author: seherv

examples/workflow/async_activities.py

@@ -63,7 +63,9 @@ async def fetch_url(ctx: wf.WorkflowActivityContext, request: FetchRequest) -> d
         status_code=response.status_code,
         body_length=len(response.content),
     )
-    print(f'[async] fetched {result.url} -> {result.status_code} ({result.body_length}B)', flush=True)
+    print(
+        f'[async] fetched {result.url} -> {result.status_code} ({result.body_length}B)', flush=True
+    )
     return result.model_dump()
 
 

ext/dapr-ext-workflow/dapr/ext/workflow/_durabletask/worker.py

@@ -1099,9 +1099,7 @@ def _execute_activity(
                     req, instance_id, result, completionToken
                 )
             except Exception as ex:
-                res = self._build_activity_failure_response(
-                    req, instance_id, ex, completionToken
-                )
+                res = self._build_activity_failure_response(req, instance_id, ex, completionToken)
             self._send_activity_response(req, stub, res, completionToken, instance_id)
 
     async def _execute_activity_async(
@@ -1131,9 +1129,7 @@ async def _execute_activity_async(
             except asyncio.CancelledError:
                 raise
             except Exception as ex:
-                res = self._build_activity_failure_response(
-                    req, instance_id, ex, completionToken
-                )
+                res = self._build_activity_failure_response(req, instance_id, ex, completionToken)
             loop = asyncio.get_running_loop()
             try:
                 await loop.run_in_executor(

ext/dapr-ext-workflow/dapr/ext/workflow/workflow_runtime.py

@@ -95,16 +95,12 @@ async def async_activity_wrapper(
                     return await fn(wf_ctx)
                 return await fn(wf_ctx, _coerce_activity_input(inp, input_model))
             except Exception as e:
-                logger.warning(
-                    f'Activity execution failed - task_id: {activity_id}, error: {e}'
-                )
+                logger.warning(f'Activity execution failed - task_id: {activity_id}, error: {e}')
                 raise
 
         return async_activity_wrapper
 
-    def sync_activity_wrapper(
-        ctx: task.ActivityContext, inp: object | None = None
-    ) -> object:
+    def sync_activity_wrapper(ctx: task.ActivityContext, inp: object | None = None) -> object:
         activity_id = getattr(ctx, 'task_id', 'unknown')
         try:
             wf_ctx = WorkflowActivityContext(ctx)