lint + formatter

Signed-off-by: Tim Li <[email protected]>

Author: timl3136

cadence/workflow.py

@@ -59,7 +59,13 @@ class WorkflowDefinition:
     Provides type safety and metadata for workflow classes.
     """
 
-    def __init__(self, cls: Type, name: str, run_method_name: str, signals: dict[str, Callable[..., Any]]):
+    def __init__(
+        self,
+        cls: Type,
+        name: str,
+        run_method_name: str,
+        signals: dict[str, Callable[..., Any]],
+    ):
         self._cls = cls
         self._name = name
         self._run_method_name = run_method_name
@@ -106,7 +112,9 @@ def wrap(cls: Type, opts: WorkflowDefinitionOptions) -> "WorkflowDefinition":
         # Validate that the class has exactly one run method and find it
         # Also validate that class does not have multiple signal methods with the same name
         signals: dict[str, Callable[..., Any]] = {}
-        signal_names: dict[str, str] = {}  # Map signal name to method name for duplicate detection
+        signal_names: dict[
+            str, str
+        ] = {}  # Map signal name to method name for duplicate detection
         run_method_name = None
         for attr_name in dir(cls):
             if attr_name.startswith("_"):
@@ -123,7 +131,7 @@ def wrap(cls: Type, opts: WorkflowDefinitionOptions) -> "WorkflowDefinition":
                         f"Multiple @workflow.run methods found in class {cls.__name__}"
                     )
                 run_method_name = attr_name
-            
+
             if hasattr(attr, "_workflow_signal"):
                 signal_name = getattr(attr, "_workflow_signal")
                 if signal_name in signal_names:
@@ -140,7 +148,6 @@ def wrap(cls: Type, opts: WorkflowDefinitionOptions) -> "WorkflowDefinition":
         return WorkflowDefinition(cls, name, run_method_name, signals)
 
 
-
 def run(func: Optional[T] = None) -> Union[T, Callable[[T], T]]:
     """
     Decorator to mark a method as the main workflow run method.
@@ -181,12 +188,13 @@ def decorator(f: T) -> T:
         # Called without parentheses: @workflow.run
         return decorator(func)
 
+
 def signal(name: str | None = None) -> Callable[[T], T]:
     """
     Decorator to mark a method as a workflow signal handler.
 
     Example:
-       	@workflow.signal(name="approval_channel")
+        @workflow.signal(name="approval_channel")
         async def approve(self, approved: bool):
             self.approved = approved
 
@@ -205,10 +213,12 @@ async def approve(self, approved: bool):
 
     def decorator(f: T) -> T:
         f._workflow_signal = name  # type: ignore
-        return f    
+        return f
+
     # Only allow @workflow.signal(name), require name to be explicitly provided
     return decorator
 
+
 @dataclass
 class WorkflowInfo:
     workflow_type: str

tests/cadence/worker/test_registry.py

@@ -256,12 +256,19 @@ async def handle_cancel(self):
         assert len(workflow_def.signals) == 2
         assert "handle_approval" in workflow_def.signals
         assert "handle_cancel" in workflow_def.signals
-        assert getattr(workflow_def.signals["handle_approval"], "_workflow_signal") == "approval"
-        assert getattr(workflow_def.signals["handle_cancel"], "_workflow_signal") == "cancel"
+        assert (
+            getattr(workflow_def.signals["handle_approval"], "_workflow_signal")
+            == "approval"
+        )
+        assert (
+            getattr(workflow_def.signals["handle_cancel"], "_workflow_signal")
+            == "cancel"
+        )
 
     def test_signal_decorator_requires_name(self):
         """Test that signal decorator requires name parameter."""
         with pytest.raises(ValueError, match="name is required"):
+
             @workflow.signal()
             async def test_signal(self):
                 pass
@@ -284,7 +291,10 @@ def test_duplicate_signal_names_error(self):
         """Test that duplicate signal names raise ValueError."""
         reg = Registry()
 
-        with pytest.raises(ValueError, match="Multiple.*signal.*found.*with signal name 'approval'"):
+        with pytest.raises(
+            ValueError, match="Multiple.*signal.*found.*with signal name 'approval'"
+        ):
+
             @reg.workflow
             class WorkflowWithDuplicateSignalNames:
                 @workflow.run