fix: namespace propagation from spawn_workflow (#43)

* fix: update requirements to indicate python version >=3.10

* fix: don't double-set namespace from spawn_workflow

hatchet_sdk/clients/admin.py

@@ -135,7 +135,9 @@ async def run_workflow(
             if not self.pooled_workflow_listener:
                 self.pooled_workflow_listener = PooledWorkflowRunListener(self.config)
 
-            workflow_name = f"{self.namespace}{workflow_name}"
+            # if workflow_name does not start with namespace, prepend it
+            if self.namespace != "" and not workflow_name.startswith(self.namespace):
+                workflow_name = f"{self.namespace}{workflow_name}"
 
             request = self._prepare_workflow_request(workflow_name, input, options)
             resp: TriggerWorkflowResponse = await self.aio_client.TriggerWorkflow(
@@ -276,7 +278,8 @@ def run_workflow(
             if not self.pooled_workflow_listener:
                 self.pooled_workflow_listener = PooledWorkflowRunListener(self.config)
 
-            workflow_name = f"{self.namespace}{workflow_name}"
+            if self.namespace != "" and not workflow_name.startswith(self.namespace):
+                workflow_name = f"{self.namespace}{workflow_name}"
 
             request = self._prepare_workflow_request(workflow_name, input, options)
             resp: TriggerWorkflowResponse = self.client.TriggerWorkflow(

hatchet_sdk/context.py

@@ -64,6 +64,7 @@ async def spawn_workflow(
         self, workflow_name: str, input: dict = {}, key: str = None
     ) -> WorkflowRunRef:
         options = self._prepare_workflow_options(key)
+
         return await self.admin_client.aio.run_workflow(workflow_name, input, options)
 
 
@@ -170,8 +171,6 @@ def playground(self, name: str, default: str = None):
         return default
 
     def spawn_workflow(self, workflow_name: str, input: dict = {}, key: str = None):
-        workflow_name = f"{self.namespace}{workflow_name}"
-
         options = self._prepare_workflow_options(key)
 
         return self.admin_client.run_workflow(workflow_name, input, options)

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "hatchet-sdk"
-version = "0.26.2"
+version = "0.26.3"
 description = ""
 authors = ["Alexander Belanger <[email protected]>"]
 readme = "README.md"