Skip to content

Commit 9a0dde3

Browse files
committed
Use updated core which is OK with dupe run ids
1 parent 11b7365 commit 9a0dde3

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

temporalio/worker/replayer.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,14 +24,14 @@
2424
)
2525

2626
import google.protobuf.json_format
27-
from temporalio.bridge.temporal_sdk_bridge import HistoryPusher
2827
from typing_extensions import TypedDict
2928

3029
import temporalio.api.history.v1
3130
import temporalio.bridge.proto.workflow_activation
3231
import temporalio.bridge.worker
3332
import temporalio.converter
3433
import temporalio.workflow
34+
from temporalio.bridge.temporal_sdk_bridge import HistoryPusher
3535

3636
from .interceptor import Interceptor
3737
from .worker import load_default_build_id
@@ -204,11 +204,12 @@ def _replayer_eviction_hook(
204204
]:
205205
def retfn(run_id, remove_job):
206206
ex = None
207-
if (
208-
remove_job.reason
209-
== temporalio.bridge.proto.workflow_activation.RemoveFromCache.EvictionReason.CACHE_FULL
210-
):
211-
# Cache being full doesn't count as a failure-inducing eviction
207+
ok_reasons = [
208+
temporalio.bridge.proto.workflow_activation.RemoveFromCache.EvictionReason.CACHE_FULL,
209+
temporalio.bridge.proto.workflow_activation.RemoveFromCache.EvictionReason.LANG_REQUESTED,
210+
]
211+
if remove_job.reason in ok_reasons:
212+
# These reasons don't count as a failure-inducing eviction
212213
pass
213214
elif (
214215
remove_job.reason

0 commit comments

Comments
 (0)