Skip to content

Commit 7ae97d0

Browse files
committed
Fix a few more typing errors
1 parent 853f603 commit 7ae97d0

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

temporalio/contrib/openai_agents/_trace_interceptor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -426,11 +426,11 @@ async def start_child_workflow(
426426
input=input,
427427
)
428428
if sys.version_info >= (3, 11):
429-
handle = await asyncio.create_task(
429+
handle: temporalio.workflow.ChildWorkflowHandle = await asyncio.create_task(
430430
self.next.start_child_workflow(input), context=ctx
431431
)
432432
else:
433-
handle = await ctx.run(
433+
handle: temporalio.workflow.ChildWorkflowHandle = await ctx.run(
434434
asyncio.create_task, self.next.start_child_workflow(input)
435435
)
436436
if span:

temporalio/contrib/opentelemetry.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -421,11 +421,9 @@ async def handle_signal(self, input: temporalio.worker.HandleSignalInput) -> Non
421421
# header given
422422
with self._top_level_workflow_context(success_is_complete=False) as ctx:
423423
if sys.version_info >= (3, 11):
424-
return await asyncio.create_task(
425-
self._handle_signal(input), context=ctx
426-
)
424+
await asyncio.create_task(self._handle_signal(input), context=ctx)
427425
else:
428-
return await ctx.run(asyncio.create_task, self._handle_signal(input))
426+
await ctx.run(asyncio.create_task, self._handle_signal(input))
429427

430428
async def _handle_signal(self, input: temporalio.worker.HandleSignalInput) -> None:
431429
"""Implementation of

0 commit comments

Comments
 (0)