fix: remove unused mutex

openmeterio · Aug 21, 2024 · bceb056 · bceb056
1 parent 8f76696
commit bceb056
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/internal/entitlement/balanceworker/ingesthandler.go b/internal/entitlement/balanceworker/ingesthandler.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"sync"
 
 	"github.com/openmeterio/openmeter/internal/entitlement"
 	"github.com/openmeterio/openmeter/internal/event/metadata"
@@ -13,12 +12,7 @@ import (
 	"github.com/openmeterio/openmeter/pkg/slicesx"
 )
 
-var ss sync.Mutex
-
 func (w *Worker) handleBatchedIngestEvent(ctx context.Context, event ingestevents.EventBatchedIngest) error {
-	ss.Lock()
-	defer ss.Unlock()
-
 	filters := slicesx.Map(event.Events, func(e ingestevents.IngestEventData) IngestEventQueryFilter {
 		return IngestEventQueryFilter{
 			Namespace:  e.Namespace.ID,