Skip to content

Commit

Permalink
close metrics (#103)
Browse files Browse the repository at this point in the history
  • Loading branch information
calbera authored Jun 20, 2024
1 parent ebb24ef commit 125df08
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions baseapp/job_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -126,6 +126,11 @@ func (jm *JobManager) Stop() {

// Wait for both to finish.
wg.Wait()

// Close the metrics.
if err := jm.ctxFactory.metrics.Close(); err != nil {
jm.ctxFactory.logger.Error("failed to close metrics", "err", err)
}
}

// RunProducers sets up each job and runs its producer.
Expand Down

0 comments on commit 125df08

Please sign in to comment.