anchor.diff:      
       % wait for documents to expire 
       timer:sleep(timer:seconds(70)),
  -
  -    assert_storage_cleaned_up(Worker, StorageId),
  +    
  +    assert_storage_cleaned_up(Worker, storage_mount_point(Worker, StorageId)),
       assert_synced_documents_cleaned_up(Worker, ?SPACE_ID),
       assert_local_documents_cleaned_up(Worker).
   
  
positive.code: check_exists_on_storage(Worker, StorageFilePath) ->
      rpc:call(Worker, filelib, is_file, [StorageFilePath]).
  
  storage_file_path(Worker, SpaceId, FilePath, true) ->
      SpaceMnt = get_space_mount_point(Worker, SpaceId),
      filename:join([SpaceMnt, FilePath]);
  
negative.code:     check_files_on_storage(Worker, AllPaths, true, true),
      check_distribution(Workers, SessId, [], G1),
      check_distribution(Workers, SessId, [], G2),
  
      ok = lfm_proxy:unlink(Worker, SessId(Worker), {guid, G1}),
      ok = lfm_proxy:unlink(Worker, SessId(Worker), {guid, G2}),
      ok = lfm_proxy:unlink(Worker, SessId(Worker), {guid, DirGuid}),
      
      % files on storage have to be deleted manually as only file location documents have 
      % been deleted during cleanup traverse on imported storage
      ok = remove_storage_file(Worker, storage_file_path(Worker, ?SPACE_ID, F1Path, true)),
      ok = remove_storage_file(Worker, storage_file_path(Worker, ?SPACE_ID, F2Path, true)),
      ok = remove_storage_dir(Worker, storage_file_path(Worker, ?SPACE_ID, DirPath, true)).
  
  
  cleanup_traverse_stage_persistence_test(Config) ->
  