Remove erroneous error check

elastic · May 16, 2024 · 025e137 · 025e137
1 parent 355920f
commit 025e137
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/x-pack/filebeat/input/azureeventhub/v1_input.go b/x-pack/filebeat/input/azureeventhub/v1_input.go
@@ -69,12 +69,8 @@ func (in *eventHubInputV1) Run(
 	defer in.pipelineClient.Close()
 
 	// Setup input metrics
-	inputMetrics := newInputMetrics(inputContext.ID, nil)
-	if err != nil {
-		return fmt.Errorf("failed to create input metrics: %w", err)
-	}
-	defer inputMetrics.Close()
-	in.metrics = inputMetrics
+	in.metrics = newInputMetrics(inputContext.ID, nil)
+	defer in.metrics.Close()
 
 	ctx := v2.GoContextFromCanceler(inputContext.Cancelation)