anchor.diff:      
       assert_synced_documents_cleaned_up(Worker1, ?SPACE_ID),
   
  -    clean_and_wait(Worker2, Worker1, SessId, [G1, G2, DirGuid]).
  +    delete_files_and_wait_for_sync(Worker2, Workers, SessId, [G1, G2, DirGuid]).
       
   
   delete_local_documents_stage_test(Config) ->
  
positive.code:     end, Workers),
      Worker.
  
  clean_and_wait(CleanOnWorker, CheckOnWorker, SessId, Guids) ->
      lists:foreach(fun(Guid) ->
          ?assertEqual(ok, lfm_proxy:unlink(CleanOnWorker, SessId(CleanOnWorker), ?FILE_REF(Guid)))
      end, Guids),
  
      lists:foreach(fun(Guid) ->
          ?assertEqual({error, ?ENOENT}, lfm_proxy:stat(CheckOnWorker, SessId(CheckOnWorker), ?FILE_REF(Guid)), ?ATTEMPTS)
      end, Guids).
negative.code:     check_distribution(Workers, SessId, [], G1),
      check_distribution(Workers, SessId, [], G2),
  
      delete_files_and_wait_for_sync(Worker, Workers, SessId, [G1, G2, DirGuid]),
      
      % files on storage have to be deleted manually as only file location documents have 
      % been deleted during cleanup traverse on imported storage
  