Skip to content

Commit

Permalink
Fix some lint errors
Browse files Browse the repository at this point in the history
  • Loading branch information
dandavison committed Jan 22, 2025
1 parent 154aab9 commit 0fe9275
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
6 changes: 4 additions & 2 deletions temporalio/worker/_workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,7 @@ async def run(self) -> None:

def notify_shutdown(self) -> None:
if self._could_not_evict_count:
logger.warn(
logger.warning(
f"Shutting down workflow worker, but {self._could_not_evict_count} "
+ "workflow(s) could not be evicted previously, so the shutdown will hang"
)
Expand Down Expand Up @@ -244,7 +244,9 @@ async def _handle_activation(
self._running_workflows[act.run_id] = workflow
elif init_job:
# This should never happen
logger.warn("Cache already exists for activation with initialize job")
logger.warning(
"Cache already exists for activation with initialize job"
)

# Run activation in separate thread so we can check if it's
# deadlocked
Expand Down
2 changes: 1 addition & 1 deletion tests/helpers/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
import uuid
from contextlib import closing
from datetime import timedelta
from typing import Any, Awaitable, Callable, Optional, Sequence, Type, TypeVar
from typing import Awaitable, Callable, Optional, Sequence, Type, TypeVar

from temporalio.api.common.v1 import WorkflowExecution
from temporalio.api.enums.v1 import IndexedValueType
Expand Down

0 comments on commit 0fe9275

Please sign in to comment.