helm/ambient-local-exporter/Chart.yaml

@@ -15,13 +15,13 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.6
+version: 0.1.5
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-appVersion: "v0.12.1"
+appVersion: "v0.12.0"
 
 dependencies:
   - name: hull

pkg/ambient/ambient.go

@@ -163,43 +163,24 @@ func (aw *AmbientWeather) handleProviderRequest(
 		updateSpan.SetAttributes(attribute.String("stationName", update.StationConfig.Name))
 	}
 
-	// Concurrently record the now enriched update
-	// to the configured recorder and to otel, and proxy
-	// to enabled downstream providers
-	var updateWg sync.WaitGroup
-
 	// Record state
-	updateWg.Add(1)
+	aw.weatherRecorder.Set(ctx, update)
-	go func() {
-		defer updateWg.Done()
-		aw.weatherRecorder.Set(ctx, update)
-	}()
 
 	// Update metrics
-	updateWg.Add(1)
+	aw.metricsUpdate(ctx, p, update)
-	go func() {
-		defer updateWg.Done()
-		aw.metricsUpdate(ctx, p, update)
-	}()
-
-	// Proxy update to one or both services if configured to do so
-	// Uses a weather update to allow awn to publish to wunderground and
-	// visa versa.
-	if update.StationConfig != nil {
-		updateWg.Add(1)
-		go func() {
-			defer updateWg.Done()
-			aw.proxyUpdate(ctx, p, update)
-		}()
-	}
-
-	updateWg.Wait()
 
 	l.Debug().
 		Str("provider", p.Name()).
 		Any("update", update).
 		Msg("successfully handled update")
 	w.Write([]byte("ok"))
+
+	// Proxy update to one or both services if configured to do so
+	// Uses a weather update to allow awn to publish to wunderground and
+	// visa versa.
+	if update.StationConfig != nil {
+		aw.proxyUpdate(ctx, p, update)
+	}
 }
 
 func (aw *AmbientWeather) enrichUpdate(