Merge branch 'main' into static_plugin

Author: tconley1428

temporalio/client.py

@@ -465,7 +465,7 @@ async def start_workflow(
         args: Sequence[Any] = [],
         id: str,
         task_queue: str,
-        result_type: Optional[Type] = None,
+        result_type: Optional[type] = None,
         execution_timeout: Optional[timedelta] = None,
         run_timeout: Optional[timedelta] = None,
         task_timeout: Optional[timedelta] = None,
@@ -500,7 +500,7 @@ async def start_workflow(
         args: Sequence[Any] = [],
         id: str,
         task_queue: str,
-        result_type: Optional[Type] = None,
+        result_type: Optional[type] = None,
         execution_timeout: Optional[timedelta] = None,
         run_timeout: Optional[timedelta] = None,
         task_timeout: Optional[timedelta] = None,
@@ -746,7 +746,7 @@ async def execute_workflow(
         args: Sequence[Any] = [],
         id: str,
         task_queue: str,
-        result_type: Optional[Type] = None,
+        result_type: Optional[type] = None,
         execution_timeout: Optional[timedelta] = None,
         run_timeout: Optional[timedelta] = None,
         task_timeout: Optional[timedelta] = None,
@@ -781,7 +781,7 @@ async def execute_workflow(
         args: Sequence[Any] = [],
         id: str,
         task_queue: str,
-        result_type: Optional[Type] = None,
+        result_type: Optional[type] = None,
         execution_timeout: Optional[timedelta] = None,
         run_timeout: Optional[timedelta] = None,
         task_timeout: Optional[timedelta] = None,

temporalio/workflow.py

@@ -2210,7 +2210,7 @@ def start_activity(
     *,
     args: Sequence[Any] = [],
     task_queue: Optional[str] = None,
-    result_type: Optional[Type] = None,
+    result_type: Optional[type] = None,
     schedule_to_close_timeout: Optional[timedelta] = None,
     schedule_to_start_timeout: Optional[timedelta] = None,
     start_to_close_timeout: Optional[timedelta] = None,
@@ -2230,7 +2230,7 @@ def start_activity(
     *,
     args: Sequence[Any] = [],
     task_queue: Optional[str] = None,
-    result_type: Optional[Type] = None,
+    result_type: Optional[type] = None,
     schedule_to_close_timeout: Optional[timedelta] = None,
     schedule_to_start_timeout: Optional[timedelta] = None,
     start_to_close_timeout: Optional[timedelta] = None,
@@ -2426,7 +2426,7 @@ async def execute_activity(
     *,
     args: Sequence[Any] = [],
     task_queue: Optional[str] = None,
-    result_type: Optional[Type] = None,
+    result_type: Optional[type] = None,
     schedule_to_close_timeout: Optional[timedelta] = None,
     schedule_to_start_timeout: Optional[timedelta] = None,
     start_to_close_timeout: Optional[timedelta] = None,
@@ -2446,7 +2446,7 @@ async def execute_activity(
     *,
     args: Sequence[Any] = [],
     task_queue: Optional[str] = None,
-    result_type: Optional[Type] = None,
+    result_type: Optional[type] = None,
     schedule_to_close_timeout: Optional[timedelta] = None,
     schedule_to_start_timeout: Optional[timedelta] = None,
     start_to_close_timeout: Optional[timedelta] = None,