diff --git a/operator/pkg/operator.go b/operator/pkg/operator.go
index d4c36355cb..af4c5d42ac 100644
--- a/operator/pkg/operator.go
+++ b/operator/pkg/operator.go
@@ -239,7 +239,7 @@ func (o *Operator) Start(ctx context.Context) error {
 			}
 		case err := <-subV3:
 			o.Logger.Infof("Error in websocket subscription", "err", err)
-			subV2, err = o.SubscribeToNewTasksV3()
+			subV3, err = o.SubscribeToNewTasksV3()
 			if err != nil {
 				o.Logger.Fatal("Could not subscribe to new tasks V3")
 			}