anchor.diff:      end, Workers),
       Worker.
   
  -clean_and_wait(CleanOnWorker, CheckOnWorker, SessId, Guids) ->
  +delete_files_and_wait_for_sync(DeletingWorker, AllWorkers, SessId, Guids) ->
       lists:foreach(fun(Guid) ->
  -        ?assertEqual(ok, lfm_proxy:unlink(CleanOnWorker, SessId(CleanOnWorker), ?FILE_REF(Guid)))
  +        ?assertEqual(ok, lfm_proxy:unlink(DeletingWorker, SessId(DeletingWorker), ?FILE_REF(Guid)))
       end, Guids),
   
  -    lists:foreach(fun(Guid) ->
  -        ?assertEqual({error, ?ENOENT}, lfm_proxy:stat(CheckOnWorker, SessId(CheckOnWorker), ?FILE_REF(Guid)), ?ATTEMPTS)
  -    end, Guids).+    SyncWorkers = AllWorkers -- [DeletingWorker],
  +    lists:foreach(fun(SyncWorker) ->
  +        lists:foreach(fun(Guid) ->
  +            ?assertEqual({error, ?ENOENT}, lfm_proxy:stat(SyncWorker, SessId(SyncWorker), ?FILE_REF(Guid)), ?ATTEMPTS)
  +        end, Guids)
  +    end, SyncWorkers).
positive.code:     
      assert_synced_documents_cleaned_up(Worker1, ?SPACE_ID),
  
      clean_and_wait(Worker2, Worker1, SessId, [G1, G2, DirGuid]).
      
  
  delete_local_documents_stage_test(Config) ->
  
negative.code:     check_distribution(Workers, SessId, [], G1),
      check_distribution(Workers, SessId, [], G2),
  
      delete_files_and_wait_for_sync(Worker, Workers, SessId, [G1, G2, DirGuid]).
  
  
  cleanup_traverse_stage_with_import_test(Config) ->
  