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: %%% 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) ->
      ?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])),
  
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) ->
  