Skip to content

Commit 1d89d75

Browse files
authored
Fix some lint errors (#744)
1 parent 154aab9 commit 1d89d75

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

temporalio/worker/_workflow.py

+4-2
Original file line numberDiff line numberDiff line change
@@ -180,7 +180,7 @@ async def run(self) -> None:
180180

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

249251
# Run activation in separate thread so we can check if it's
250252
# deadlocked

tests/helpers/__init__.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import uuid
55
from contextlib import closing
66
from datetime import timedelta
7-
from typing import Any, Awaitable, Callable, Optional, Sequence, Type, TypeVar
7+
from typing import Awaitable, Callable, Optional, Sequence, Type, TypeVar
88

99
from temporalio.api.common.v1 import WorkflowExecution
1010
from temporalio.api.enums.v1 import IndexedValueType

0 commit comments

Comments
 (0)