diff --git a/go.mod b/go.mod
index f43e81f..3985c83 100644
--- a/go.mod
+++ b/go.mod
@@ -67,7 +67,7 @@ require (
 	github.com/x448/float16 v0.8.4 // indirect
 	github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
-	go.uber.org/zap v1.27.0 // indirect
+	go.uber.org/zap v1.27.0
 	golang.org/x/crypto v0.26.0 // indirect
 	golang.org/x/net v0.28.0 // indirect
 	golang.org/x/sys v0.24.0 // indirect
diff --git a/taskfiles/Taskfile_gotest.yml b/taskfiles/Taskfile_gotest.yml
index 542ad5f..7fd66f4 100644
--- a/taskfiles/Taskfile_gotest.yml
+++ b/taskfiles/Taskfile_gotest.yml
@@ -38,7 +38,7 @@ tasks:
             -v \
             -coverprofile={{.UNITTEST_DIR}}/main.out \
             ./...
-          gocov convert {{.UNITTEST_DIR}}/main.out > {{.UNITTEST_DIR}}/coverage.json
+          # gocov convert {{.UNITTEST_DIR}}/main.out > {{.UNITTEST_DIR}}/coverage.json
 
   go:prodpublic:
     desc: "run the integration tests"
@@ -59,7 +59,7 @@ tasks:
             -v \
             -coverprofile={{.UNITTEST_DIR}}/main.out \
             ./...
-          gocov convert {{.UNITTEST_DIR}}/main.out > {{.UNITTEST_DIR}}/coverage.json
+          # gocov convert {{.UNITTEST_DIR}}/main.out > {{.UNITTEST_DIR}}/coverage.json
 
 
   go:unit:
@@ -80,4 +80,4 @@ tasks:
             -v \
             -coverprofile={{.UNITTEST_DIR}}/main.out \
             ./...
-          gocov convert {{.UNITTEST_DIR}}/main.out > {{.UNITTEST_DIR}}/coverage.json
\ No newline at end of file
+          # gocov convert {{.UNITTEST_DIR}}/main.out > {{.UNITTEST_DIR}}/coverage.json
diff --git a/veracitytesting/testeventgenerator.go b/veracitytesting/testeventgenerator.go
index 04e9a36..847c2a8 100644
--- a/veracitytesting/testeventgenerator.go
+++ b/veracitytesting/testeventgenerator.go
@@ -11,12 +11,10 @@ import (
 
 	"github.com/datatrails/go-datatrails-common-api-gen/assets/v2/assets"
 	"github.com/datatrails/go-datatrails-common-api-gen/attribute/v2/attribute"
-	"github.com/datatrails/go-datatrails-common/azbus"
 	"github.com/datatrails/go-datatrails-merklelog/massifs/snowflakeid"
 	"github.com/datatrails/go-datatrails-merklelog/mmrtesting"
 	"github.com/datatrails/go-datatrails-simplehash/simplehash"
 	"github.com/stretchr/testify/require"
-	"google.golang.org/protobuf/encoding/protojson"
 	"google.golang.org/protobuf/types/known/timestamppb"
 )
 
@@ -143,27 +141,6 @@ func (g *EventTestGenerator) GenerateEventBatch(count int) []*assets.EventRespon
 	return events
 }
 
-func (g *EventTestGenerator) GenerateTenantEventMessageBatch(tenantIdentity string, count int) []*azbus.ReceivedMessage {
-	msgs := make([]*azbus.ReceivedMessage, 0, count)
-	for range count {
-		event := assets.EventMessage{
-			TenantId: tenantIdentity,
-			Event:    g.GenerateNextEvent(tenantIdentity),
-		}
-		m := protojson.MarshalOptions{UseProtoNames: true}
-		data, err := m.Marshal(&event)
-		if err != nil {
-			g.T.Fatalf("failed to marshal event: %v", err)
-		}
-
-		props := make(map[string]any)
-		props[resourceChangedProperty] = resourceChangeMerkleLogStoredEvent
-
-		msgs = append(msgs, &azbus.ReceivedMessage{Body: data, ApplicationProperties: props})
-	}
-	return msgs
-}
-
 func (g *EventTestGenerator) GenerateNextEvent(tenantIdentity string) *assets.EventResponse {
 
 	assetIdentity := g.NewAssetIdentity()