Skip to content
This repository was archived by the owner on Apr 1, 2026. It is now read-only.

Commit e428bf0

Browse files
committed
removed export interval option
1 parent 987e3df commit e428bf0

2 files changed

Lines changed: 5 additions & 24 deletions

File tree

google/cloud/bigtable/data/_metrics/handlers/gcp_exporter.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,9 @@
8181
for n in INSTRUMENT_NAMES
8282
]
8383

84+
# We use the minimum value supported by the Cloud Monitoring API (60 seconds)
85+
EXPORT_INTERVAL_MS = 60_000
86+
8487

8588
class GoogleCloudMetricsHandler(OpenTelemetryMetricsHandler):
8689
"""
@@ -102,12 +105,12 @@ class GoogleCloudMetricsHandler(OpenTelemetryMetricsHandler):
102105
- export_interval: The interval (in seconds) at which to export metrics to Cloud Monitoring.
103106
"""
104107

105-
def __init__(self, *args, project_id: str, export_interval=60, **kwargs):
108+
def __init__(self, *args, project_id: str, **kwargs):
106109
# internal exporter to write metrics to Cloud Monitoring
107110
exporter = _BigtableMetricsExporter(project_id=project_id)
108111
# periodically executes exporter
109112
gcp_reader = PeriodicExportingMetricReader(
110-
exporter, export_interval_millis=export_interval * 1000
113+
exporter, export_interval_millis=EXPORT_INTERVAL_MS
111114
)
112115
# use private meter provider to store instruments and views
113116
meter_provider = MeterProvider(metric_readers=[gcp_reader], views=VIEW_LIST)

tests/unit/data/_metrics/handlers/test_handler_gcp_exporter.py

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -100,28 +100,6 @@ def test_uses_custom_meter_provider(self, mock_meter_provider, mock_instruments)
100100
assert isinstance(found_reader._exporter, _BigtableMetricsExporter)
101101
assert found_reader._exporter.project_name == f"projects/{project_id}"
102102

103-
@mock.patch(
104-
"google.cloud.bigtable.data._metrics.handlers.gcp_exporter.PeriodicExportingMetricReader",
105-
autospec=True,
106-
)
107-
def test_custom_export_interval(self, mock_reader):
108-
"""
109-
should be able to set a custom export interval
110-
"""
111-
input_interval = 123
112-
try:
113-
self._make_one(
114-
export_interval=input_interval,
115-
project_id="p",
116-
instance_id="i",
117-
table_id="t",
118-
)
119-
except Exception:
120-
pass
121-
reader_init_kwargs = mock_reader.call_args[1]
122-
found_interval = reader_init_kwargs["export_interval_millis"]
123-
assert found_interval == input_interval * 1000 # convert to ms
124-
125103

126104
class Test_BigtableMetricsExporter:
127105
def _get_class(self):

0 commit comments

Comments
 (0)