lint

Author: yuandrew

temporalio/bridge/runtime.py

@@ -96,7 +96,7 @@ class RuntimeOptions:
     """Python representation of the Rust struct for runtime options."""
 
     telemetry: TelemetryConfig
-    worker_heartbeat_interval_millis: Optional[int] = None
+    worker_heartbeat_interval_millis: Optional[int] = 30000 # 30s
 
 
 # WARNING: This must match Rust runtime::BufferedLogEntry

temporalio/runtime.py

@@ -422,7 +422,7 @@ class RuntimeOptions:
     telemetry: TelemetryConfig = field(default_factory=TelemetryConfig)
     """Telemetry configuration applied to the runtime."""
 
-    worker_heartbeat_interval: Optional[timedelta] = None
+    worker_heartbeat_interval: Optional[timedelta] = timedelta(seconds=30)
     """Interval for worker heartbeats. ``None`` disables heartbeating."""
 
     def _to_bridge_config(self) -> temporalio.bridge.runtime.RuntimeOptions:

tests/test_plugins.py

@@ -6,10 +6,10 @@
 
 import pytest
 
+import temporalio.bridge.temporal_sdk_bridge
 import temporalio.client
 import temporalio.converter
 import temporalio.worker
-import temporalio.bridge.temporal_sdk_bridge
 from temporalio import workflow
 from temporalio.client import Client, ClientConfig, OutboundInterceptor, WorkflowHistory
 from temporalio.contrib.pydantic import pydantic_data_converter

tests/worker/test_worker.py

@@ -16,6 +16,7 @@
 from temporalio.api.workflowservice.v1 import (
     DescribeWorkerDeploymentRequest,
     DescribeWorkerDeploymentResponse,
+    ListWorkersRequest,
     SetWorkerDeploymentCurrentVersionRequest,
     SetWorkerDeploymentCurrentVersionResponse,
     SetWorkerDeploymentRampingVersionRequest,
@@ -27,7 +28,12 @@
     TaskReachabilityType,
 )
 from temporalio.common import PinnedVersioningOverride, RawValue, VersioningBehavior
-from temporalio.runtime import PrometheusConfig, Runtime, TelemetryConfig
+from temporalio.runtime import (
+    PrometheusConfig,
+    Runtime,
+    RuntimeOptions,
+    TelemetryConfig,
+)
 from temporalio.service import RPCError
 from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import (