Hotfix: Task + Timeout (#1433)

* hotfix: simple task

* fix: add back timeout

* debug: try using loop scoped to session

* fix: decrease timeout

* fix: doc path

Author: mrkaye97

.github/workflows/sdk-python.yml

@@ -134,7 +134,7 @@ jobs:
         run: |
           echo "Using HATCHET_CLIENT_NAMESPACE: $HATCHET_CLIENT_NAMESPACE"
 
-          poetry run pytest -s -vvv --maxfail=5 --capture=no -n 5
+          poetry run pytest -s -vvv --maxfail=5 --capture=no -n 5 --timeout 60
 
       - name: Upload engine logs
         if: always()

frontend/docs/components/code/codeData.tsx

@@ -42,7 +42,7 @@ const getUIUrl = ({ user, repo, branch, path }: RepoProps) => {
   if (isDev) {
     return getLocalUrl(ext, { path });
   }
-  return `https://github.com/${user || defaultUser}/${repo || defaultRepo}/blob/${branch || defaultBranch}/${path}`;
+  return `https://github.com/${user || defaultUser}/${repo || defaultRepo}/blob/${branch || defaultBranch}/${localPaths[ext]}/${path}`;
 };
 
 export type Src = {

frontend/docs/pages/home/your-first-task.mdx

@@ -34,10 +34,18 @@ The returned object is an instance of the `StandaloneTaskWorkflow` class, which
 
 ```python
 from hatchet_sdk import Context, EmptyModel, Hatchet
+from pydantic import BaseModel
 
 hatchet = Hatchet(debug=True)
 
-simple = hatchet.workflow(name="SimpleWorkflow")
+class SimpleInput(BaseModel):
+    message: str
+
+hatchet.task(name="SimpleWorkflow")
+def simple(input: SimpleInput, ctx: Context) -> dict[str, str]:
+    return {
+      "transformed_message": input.message.lower(),
+    }
 ```
 
 </Tabs.Tab>
@@ -72,13 +80,7 @@ With your task defined, you can import it wherever you need to use it and invoke
   <Tabs.Tab title="Python">
 
 ```python
-from hatchet_sdk import Context, EmptyModel, Hatchet
-
-hatchet = Hatchet(debug=True)
-
-@hatchet.task(name="SimpleWorkflow")
-def step1(input: EmptyModel, ctx: Context) -> None:
-    print("executed step1")
+simple.run(SimpleInput(message="HeLlO WoRlD"))
 ```
 
 </Tabs.Tab>

sdks/python/poetry.lock

@@ -35,6 +35,7 @@ opentelemetry-exporter-otlp = { version = "^1.28.0", optional = true }
 opentelemetry-exporter-otlp-proto-http = { version = "^1.28.0", optional = true }
 prometheus-client = "^0.21.1"
 pydantic-settings = "^2.7.1"
+pytest-timeout = "^2.3.1"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^8.3.5"

sdks/python/pyproject.toml

@@ -6,7 +6,7 @@
 from hatchet_sdk import Hatchet
 
 
-@pytest.mark.asyncio(loop_scope="function")
+@pytest.mark.asyncio(loop_scope="session")
 async def test_list_runs(hatchet: Hatchet) -> None:
     dag_result = await dag_workflow.aio_run()
 
@@ -19,7 +19,7 @@ async def test_list_runs(hatchet: Hatchet) -> None:
         assert v in [r.output for r in runs.rows]
 
 
-@pytest.mark.asyncio(loop_scope="function")
+@pytest.mark.asyncio(loop_scope="session")
 async def test_get_run(hatchet: Hatchet) -> None:
     dag_ref = await dag_workflow.aio_run_no_wait()
 
@@ -33,7 +33,7 @@ async def test_get_run(hatchet: Hatchet) -> None:
     assert {t.name for t in dag_workflow.tasks} == {t.task_name for t in run.shape}
 
 
-@pytest.mark.asyncio(loop_scope="function")
+@pytest.mark.asyncio(loop_scope="session")
 async def test_list_workflows(hatchet: Hatchet) -> None:
     workflows = await hatchet.workflows.aio_list(
         workflow_name=dag_workflow.config.name, limit=1, offset=0