Skip to content

Commit 3b1956e

Browse files
committed
bump core to 45b1d7e
1 parent 59da9af commit 3b1956e

File tree

2 files changed

+3
-7
lines changed

2 files changed

+3
-7
lines changed

temporalio/worker/_worker.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -555,11 +555,7 @@ def check_activity(activity):
555555
maximum=config["max_concurrent_activity_task_polls"]
556556
)
557557

558-
worker_plugins = [plugin.name() for plugin in config.get("plugins", [])]
559-
client_plugins = [
560-
plugin.name() for plugin in config["client"].config()["plugins"]
561-
]
562-
plugins = list(set(worker_plugins + client_plugins))
558+
deduped_plugin_names = list(set([plugin.name() for plugin in self.plugins]))
563559

564560
# Create bridge worker last. We have empirically observed that if it is
565561
# created before an error is raised from the activity worker
@@ -623,7 +619,7 @@ def check_activity(activity):
623619
nexus_task_poller_behavior=config[
624620
"nexus_task_poller_behavior"
625621
]._to_bridge(),
626-
plugins=plugins,
622+
plugins=deduped_plugin_names,
627623
),
628624
)
629625

0 commit comments

Comments
 (0)