fix: move declaration inside of inner decorator

Author: mrkaye97

examples/simple/worker.py

@@ -1,10 +1,10 @@
 from dotenv import load_dotenv
 
-from hatchet_sdk import Context
-from hatchet_sdk.v2 import BaseWorkflowImpl, Hatchet
-
 load_dotenv()
 
+from hatchet_sdk import Context
+from hatchet_sdk.v2 import Hatchet
+
 hatchet = Hatchet(debug=True)
 
 

hatchet_sdk/v2/hatchet.py

@@ -211,29 +211,29 @@ def function(
         concurrency: ConcurrencyExpression | None = None,
         input_validator: Type[TWorkflowInput] | None = None,
     ) -> Callable[[Callable[[Context], R]], BaseWorkflowImpl]:
-        declaration = WorkflowDeclaration[TWorkflowInput](
-            WorkflowConfig(
-                name=name,
-                on_events=on_events,
-                on_crons=on_crons,
-                version=version,
-                timeout=timeout,
-                schedule_timeout=schedule_timeout,
-                sticky=sticky,
-                default_priority=default_priority,
-                concurrency=concurrency,
-                input_validator=input_validator
-                or cast(Type[TWorkflowInput], EmptyModel),
-            ),
-            self,
-        )
-
         def inner(func: Callable[[Context], R]) -> BaseWorkflowImpl:
+            declaration = WorkflowDeclaration[TWorkflowInput](
+                WorkflowConfig(
+                    name=name or func.__name__,
+                    on_events=on_events,
+                    on_crons=on_crons,
+                    version=version,
+                    timeout=timeout,
+                    schedule_timeout=schedule_timeout,
+                    sticky=sticky,
+                    default_priority=default_priority,
+                    concurrency=concurrency,
+                    input_validator=input_validator
+                    or cast(Type[TWorkflowInput], EmptyModel),
+                ),
+                self,
+            )
+
             class Workflow(BaseWorkflowImpl):
                 config = declaration.config
 
                 @self.step(
-                    name=name,
+                    name=declaration.config.name,
                     timeout=timeout,
                     retries=0,
                     rate_limits=[],