feat: expose HEALTH_CHECK_PORT as an env var

Author: prassanna-ravishankar

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

@@ -89,14 +89,19 @@ def __init__(
         task_queue,
         max_workers: int = 10,
         max_concurrent_activities: int = 10,
-        health_check_port: int = 80,
+        health_check_port: int | None = None,
     ):
         self.task_queue = task_queue
         self.activity_handles = []
         self.max_workers = max_workers
         self.max_concurrent_activities = max_concurrent_activities
         self.health_check_server_running = False
         self.healthy = False
+        
+        # Use environment variable if health_check_port not explicitly provided
+        if health_check_port is None:
+            health_check_port = int(os.environ.get("HEALTH_CHECK_PORT", "80"))
+            
         self.health_check_port = health_check_port
 
     @overload

src/agentex/lib/environment_variables.py

@@ -32,6 +32,8 @@ class EnvVarKeys(str, Enum):
     # Workflow Configuration
     WORKFLOW_NAME = "WORKFLOW_NAME"
     WORKFLOW_TASK_QUEUE = "WORKFLOW_TASK_QUEUE"
+    # Temporal Worker Configuration
+    HEALTH_CHECK_PORT = "HEALTH_CHECK_PORT"
     # Auth Configuration
     AUTH_PRINCIPAL_B64 = "AUTH_PRINCIPAL_B64"
 
@@ -61,8 +63,10 @@ class EnvironmentVariables(BaseModel):
     ACP_PORT: int = 8000
     # Workflow Configuration
     WORKFLOW_TASK_QUEUE: str | None = None
-    WORKFLOW_NAME: str | None = None
+    WORKFLOW_NAME: str | None = None    
     AUTH_PRINCIPAL_B64: str | None = None
+    # Temporal Worker Configuration
+    HEALTH_CHECK_PORT: int = 80
 
     @classmethod
     def refresh(cls) -> EnvironmentVariables: