anchor.diff:                                   "Falling back to old behaviour", [Other]),
                       complete_old_vb_filter_change(State1)
               end;
  -        _ ->
  +        true ->
               %% We don't expect this case (though it can still happen). And by
               %% the time new ebucketmigrator starts some of the vbuckets may
               %% have already become ready. It will complicate the logic there
               %% significantly so let's just use old vbucket filter change
               %% approach.
  -            ?log_warning("Some of new vbuckets are not ready to replicate from."
  +            ?log_warning("Some of new vbuckets are not ready to replicate from. "
                            "Will not use native vbucket filter change. "
                            "Not ready vbuckets:~n~p", [NotReady]),
               complete_old_vb_filter_change(State1)
  
positive.code:                              #had_backfill{};
                           [_,_|_] ->
                               #had_backfill{value = false}
                       end
       },
  
      State1 = process_data(<<>>, #state.downbuf, fun process_downstream/2, State),
  
negative.code:             ok
      end,
  
      true = not(TakeOver andalso (ReadyVBuckets =:= [])),
  
      case OldState =:= undefined orelse ReadyVBuckets =:= [] of
          true ->
              ok = kill_tapname(UpstreamAux, TapName, Bucket, Src, Username);
          _ ->
              ok
      end,
  
      {Upstream, Args} =
          case OldState =:= undefined orelse
  