Skip to content

Commit d121812

Browse files
committed
string name workflow
1 parent 1af4a55 commit d121812

File tree

1 file changed

+37
-0
lines changed

1 file changed

+37
-0
lines changed

temporalio/nexus/_operation_context.py

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -231,6 +231,43 @@ async def start_workflow(
231231
versioning_override: Optional[temporalio.common.VersioningOverride] = None,
232232
) -> WorkflowHandle[ReturnType]: ...
233233

234+
# Overload for string-name workflow
235+
@overload
236+
async def start_workflow(
237+
self,
238+
workflow: str,
239+
arg: Any = temporalio.common._arg_unset,
240+
*,
241+
args: Sequence[Any] = [],
242+
id: str,
243+
task_queue: Optional[str] = None,
244+
result_type: Optional[Type] = None,
245+
execution_timeout: Optional[timedelta] = None,
246+
run_timeout: Optional[timedelta] = None,
247+
task_timeout: Optional[timedelta] = None,
248+
id_reuse_policy: temporalio.common.WorkflowIDReusePolicy = temporalio.common.WorkflowIDReusePolicy.ALLOW_DUPLICATE,
249+
id_conflict_policy: temporalio.common.WorkflowIDConflictPolicy = temporalio.common.WorkflowIDConflictPolicy.UNSPECIFIED,
250+
retry_policy: Optional[temporalio.common.RetryPolicy] = None,
251+
cron_schedule: str = "",
252+
memo: Optional[Mapping[str, Any]] = None,
253+
search_attributes: Optional[
254+
Union[
255+
temporalio.common.TypedSearchAttributes,
256+
temporalio.common.SearchAttributes,
257+
]
258+
] = None,
259+
static_summary: Optional[str] = None,
260+
static_details: Optional[str] = None,
261+
start_delay: Optional[timedelta] = None,
262+
start_signal: Optional[str] = None,
263+
start_signal_args: Sequence[Any] = [],
264+
rpc_metadata: Mapping[str, str] = {},
265+
rpc_timeout: Optional[timedelta] = None,
266+
request_eager_start: bool = False,
267+
priority: temporalio.common.Priority = temporalio.common.Priority.default,
268+
versioning_override: Optional[temporalio.common.VersioningOverride] = None,
269+
) -> WorkflowHandle[Any]: ...
270+
234271
async def start_workflow(
235272
self,
236273
workflow: Union[str, Callable[..., Awaitable[ReturnType]]],

0 commit comments

Comments
 (0)