anchor.diff:  %%% Assertion helper functions
   %%%===================================================================
   
  -assert_storage_cleaned_up(Worker, StorageId) ->
  -    Path = storage_mount_point(Worker, StorageId),
  -    {ok, FileList} = rpc:call(Worker, file, list_dir_all, [Path]),
  -    ?assertEqual([], FileList).
  -
  -
  -assert_local_documents_cleaned_up(Worker, SpaceId, StorageId) ->
  +assert_storage_cleaned_up(Worker, Path) ->
  +    case check_exists_on_storage(Worker, Path) of
  +        true ->
  +            {ok, FileList} = rpc:call(Worker, file, list_dir_all, [Path]),
  +            ?assertEqual([], FileList);
  +        false -> ok
  +    end.
  +
  +
  +assert_space_on_storage_cleaned_up(Worker, StorageId, SpaceId) ->
  +    case rpc:call(Worker, storage, is_imported, [StorageId]) of
  +        true -> assert_storage_cleaned_up(Worker, storage_mount_point(Worker, StorageId));
  +        false -> assert_storage_cleaned_up(Worker, filename:join(get_space_mount_point(Worker, SpaceId), SpaceId))
  +    end.
  +
  +
  +assert_local_documents_cleaned_up(Worker, SpaceId) ->
       ?assertEqual({error, not_found}, rpc:call(Worker, storage_import_config, get, [SpaceId])),
       ?assertEqual({error, not_found}, rpc:call(Worker, storage_import_monitoring, get, [SpaceId])),
       ?assertEqual(undefined, rpc:call(Worker, autocleaning, get_config, [SpaceId])),
  
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:     },
      ok = rpc:call(Worker, space_unsupport, do_slave_job, [StageJob, ?TASK_ID]),
      
      assert_local_documents_cleaned_up(Worker, ?SPACE_ID).
  
  
  overall_test(Config) ->
  