chore(python-sdk): improved thread cancellation handling, docs, and custom sleep method (#134)

* feat: timeout on python steps

* chore(python-sdk): improved thread handling and docs

* docs: default timeout

python-sdk/examples/simple/worker.py

@@ -15,13 +15,14 @@ class MyWorkflow:
         print("executed step1")
         pass
 
-    @hatchet.step(parents=["step1"])
+    @hatchet.step(parents=["step1"],timeout='4s')
     def step2(self, context):
-        print("executed step2")
-        pass
+        print("started step2")
+        context.sleep(1)
+        print("finished step2")
 
 workflow = MyWorkflow()
-worker = hatchet.worker('test-worker')
+worker = hatchet.worker('test-worker', max_threads=4)
 worker.register_workflow(workflow)
 
 worker.start()

python-sdk/examples/timeout/event_test.py

@@ -0,0 +1,13 @@
+from hatchet_sdk import new_client
+from dotenv import load_dotenv
+
+load_dotenv()
+
+client = new_client()
+
+client.event.push(
+    "user:create",
+    {
+        "test": "test"
+    }
+)

python-sdk/examples/timeout/worker.py

@@ -0,0 +1,27 @@
+from hatchet_sdk import Hatchet
+from dotenv import load_dotenv
+
+load_dotenv()
+
+hatchet = Hatchet(debug=True)
+
+@hatchet.workflow(on_events=["user:create"])
+class TimeoutWorkflow:
+    def __init__(self):
+        self.my_value = "test"
+
+    @hatchet.step(timeout='4s')
+    def timeout(self, context):
+        try:
+            print("started step2")
+            context.sleep(5)
+            print("finished step2")
+        except Exception as e:
+            print("caught an exception: " + str(e))
+            raise e
+
+workflow = TimeoutWorkflow()
+worker = hatchet.worker('timeout-worker', max_threads=4)
+worker.register_workflow(workflow)
+
+worker.start()