Minor change: correction of the function name in metrics.py

google · Sep 23, 2024 · 5d641e8 · 5d641e8
1 parent 9ae4561
commit 5d641e8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/weather_mv/loader_pipeline/metrics.py b/weather_mv/loader_pipeline/metrics.py
@@ -193,8 +193,8 @@ class CreateTimeSeries(beam.DoFn):
     project: str
     region: str
 
-    def create_time_series(self, metric_name: str, metric_value: float) -> None:
-        """Writes data to a Metrics TimeSeries."""
+    def create_time_series_object(self, metric_name: str, metric_value: float) -> None:
+        """Returns a Metrics TimeSeries object."""
         series = monitoring_v3.TimeSeries()
         series.metric.type = f"custom.googleapis.com/{metric_name}"
         series.metric.labels["description"] = metric_name