Skip to content

Commit 9f9be98

Browse files
fix: health check port handling
1 parent 18e438a commit 9f9be98

File tree

1 file changed

+2
-2
lines changed
  • src/agentex/lib/core/temporal/workers

1 file changed

+2
-2
lines changed

src/agentex/lib/core/temporal/workers/worker.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ def __init__(
112112
task_queue,
113113
max_workers: int = 10,
114114
max_concurrent_activities: int = 10,
115-
health_check_port: int = int(os.environ.get("HEALTH_CHECK_PORT")),
115+
health_check_port: int | None = None,
116116
plugins: list = [],
117117
):
118118
self.task_queue = task_queue
@@ -121,7 +121,7 @@ def __init__(
121121
self.max_concurrent_activities = max_concurrent_activities
122122
self.health_check_server_running = False
123123
self.healthy = False
124-
self.health_check_port = health_check_port
124+
self.health_check_port = health_check_port if health_check_port is not None else EnvironmentVariables.refresh().HEALTH_CHECK_PORT
125125
self.plugins = plugins
126126

127127
@overload

0 commit comments

Comments
 (0)