diff --git a/tasks/blocks/drand/task.go b/tasks/blocks/drand/task.go
index 530ed1667..7309bdf1e 100644
--- a/tasks/blocks/drand/task.go
+++ b/tasks/blocks/drand/task.go
@@ -28,6 +28,7 @@ func (p *Task) ProcessTipSet(ctx context.Context, ts *types.TipSet) (model.Persi
 			attribute.String("processor", "blocks"),
 		)
 	}
+	defer span.End()
 
 	var pl model.PersistableList
 	for _, bh := range ts.Blocks() {
diff --git a/tasks/blocks/headers/task.go b/tasks/blocks/headers/task.go
index a8147e3e9..ed7242a64 100644
--- a/tasks/blocks/headers/task.go
+++ b/tasks/blocks/headers/task.go
@@ -28,6 +28,7 @@ func (p *Task) ProcessTipSet(ctx context.Context, ts *types.TipSet) (model.Persi
 			attribute.String("processor", "blocks"),
 		)
 	}
+	defer span.End()
 
 	var pl model.PersistableList
 	for _, bh := range ts.Blocks() {
diff --git a/tasks/blocks/parents/task.go b/tasks/blocks/parents/task.go
index a9361a4a7..259646d8e 100644
--- a/tasks/blocks/parents/task.go
+++ b/tasks/blocks/parents/task.go
@@ -28,6 +28,7 @@ func (p *Task) ProcessTipSet(ctx context.Context, ts *types.TipSet) (model.Persi
 			attribute.String("processor", "blocks"),
 		)
 	}
+	defer span.End()
 
 	var pl model.PersistableList
 	for _, bh := range ts.Blocks() {
diff --git a/tasks/fevmactorstats/task.go b/tasks/fevmactorstats/task.go
index 08abe4ca4..ccb7081ed 100644
--- a/tasks/fevmactorstats/task.go
+++ b/tasks/fevmactorstats/task.go
@@ -43,6 +43,8 @@ func (p *Task) ProcessTipSet(ctx context.Context, ts *types.TipSet) (model.Persi
 			attribute.String("processor", "fevmactorstats"),
 		)
 	}
+	defer span.End()
+
 	report := &visormodel.ProcessingReport{
 		Height:    int64(ts.Height()),
 		StateRoot: ts.ParentState().String(),
diff --git a/tasks/messages/blockmessage/task.go b/tasks/messages/blockmessage/task.go
index bd414c2cf..4cf0fcae8 100644
--- a/tasks/messages/blockmessage/task.go
+++ b/tasks/messages/blockmessage/task.go
@@ -26,7 +26,7 @@ func NewTask(node tasks.DataSource) *Task {
 }
 
 func (t *Task) ProcessTipSet(ctx context.Context, current *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error) {
-	ctx, span := otel.Tracer("").Start(ctx, "ProcessTipSets")
+	ctx, span := otel.Tracer("").Start(ctx, "ProcessTipSet")
 	if span.IsRecording() {
 		span.SetAttributes(
 			attribute.String("current", current.String()),
diff --git a/tasks/messages/gaseconomy/task.go b/tasks/messages/gaseconomy/task.go
index fba3bcb92..487afd823 100644
--- a/tasks/messages/gaseconomy/task.go
+++ b/tasks/messages/gaseconomy/task.go
@@ -29,7 +29,7 @@ func NewTask(node tasks.DataSource) *Task {
 }
 
 func (t *Task) ProcessTipSet(ctx context.Context, current *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error) {
-	ctx, span := otel.Tracer("").Start(ctx, "ProcessTipSets")
+	ctx, span := otel.Tracer("").Start(ctx, "ProcessTipSet")
 	if span.IsRecording() {
 		span.SetAttributes(
 			attribute.String("current", current.String()),
diff --git a/tasks/messages/message/task.go b/tasks/messages/message/task.go
index f776a50d6..9cda759d0 100644
--- a/tasks/messages/message/task.go
+++ b/tasks/messages/message/task.go
@@ -27,7 +27,7 @@ func NewTask(node tasks.DataSource) *Task {
 }
 
 func (t *Task) ProcessTipSet(ctx context.Context, current *types.TipSet) (model.Persistable, *visormodel.ProcessingReport, error) {
-	ctx, span := otel.Tracer("").Start(ctx, "ProcessTipSets")
+	ctx, span := otel.Tracer("").Start(ctx, "ProcessTipSet")
 	if span.IsRecording() {
 		span.SetAttributes(
 			attribute.String("current", current.String()),