diff --git a/da/celestia/celestia_test.go b/da/celestia/celestia_test.go
index 790564b1c..293602901 100644
--- a/da/celestia/celestia_test.go
+++ b/da/celestia/celestia_test.go
@@ -132,7 +132,7 @@ func TestSubmitBatch(t *testing.T) {
 		go func() {
 			select {
 			case event := <-HealthSubscription.Out():
-				healthStatusEvent := event.Data().(da.EventDataDAHealthStatus)
+				healthStatusEvent := event.Data().(*da.EventDataDAHealthStatus)
 				assert.Equal(tc.expectedHealthEvent.Healthy, healthStatusEvent.Healthy)
 				done <- true
 				break
diff --git a/da/utils.go b/da/utils.go
index 84040bfe1..034d55553 100644
--- a/da/utils.go
+++ b/da/utils.go
@@ -7,7 +7,7 @@ import (
 )
 
 func SubmitBatchHealthEventHelper(pubsubServer *pubsub.Server, ctx context.Context, healthy bool, err error) (ResultSubmitBatch, error) {
-	err = pubsubServer.PublishWithEvents(ctx, EventDataDAHealthStatus{Healthy: healthy, Error: err},
+	err = pubsubServer.PublishWithEvents(ctx, &EventDataDAHealthStatus{Healthy: healthy, Error: err},
 		map[string][]string{EventTypeKey: {EventDAHealthStatus}})
 	if err != nil {
 		return ResultSubmitBatch{