diff --git a/storage/gcp/antispam/gcp.go b/storage/gcp/antispam/gcp.go
index d68228df7..5a857c69e 100644
--- a/storage/gcp/antispam/gcp.go
+++ b/storage/gcp/antispam/gcp.go
@@ -380,7 +380,9 @@ func (f *follower) Follow(ctx context.Context, lr tessera.LogReader) {
 				if err != errOutOfSync {
 					slog.ErrorContext(ctx, "Failed to commit antispam population tx", slog.Any("error", err))
 				}
-				stop()
+				if stop != nil {
+					stop()
+				}
 				next = nil
 				streamDone = true
 				continue