Skip to content

Commit

Permalink
Post-ruff-format fixups
Browse files Browse the repository at this point in the history
  • Loading branch information
dandavison committed Jun 29, 2024
1 parent e3dd27f commit d54b585
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions temporalio/worker/_activity.py
Original file line number Diff line number Diff line change
Expand Up @@ -623,8 +623,8 @@ def init(self, outbound: ActivityOutboundInterceptor) -> None:
async def execute_activity(self, input: ExecuteActivityInput) -> Any:
# Handle synchronous activity
is_async = inspect.iscoroutinefunction(input.fn) or inspect.iscoroutinefunction(
input.fn.__call__
) # type: ignore
input.fn.__call__ # type: ignore
)
if not is_async:
# We execute a top-level function via the executor. It is top-level
# because it needs to be picklable. Also, by default Python does not
Expand Down
8 changes: 4 additions & 4 deletions tests/worker/test_workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -1127,8 +1127,8 @@ async def child_started() -> bool:
return await handle.query(
CancelChildWorkflow.ready
) and await client.get_workflow_handle_for(
LongSleepWorkflow.run,
workflow_id=f"{handle.id}_child", # type: ignore[arg-type]
LongSleepWorkflow.run, # type: ignore[arg-type]
workflow_id=f"{handle.id}_child",
).query(LongSleepWorkflow.started)
except RPCError as err:
# Ignore not-found or failed precondition because child may
Expand Down Expand Up @@ -3056,8 +3056,8 @@ async def test_workflow_typed_handle(client: Client):
TypedHandleWorkflow.run, id=id, task_queue=worker.task_queue
)
handle_result: TypedHandleResponse = await client.get_workflow_handle_for(
TypedHandleWorkflow.run,
id, # type: ignore[arg-type]
TypedHandleWorkflow.run, # type: ignore[arg-type]
id,
).result()
assert isinstance(handle_result, TypedHandleResponse)

Expand Down

0 comments on commit d54b585

Please sign in to comment.