anchor.diff:  %% Creates index in given harvester.
   %% @end
   %%--------------------------------------------------------------------
  --spec harvester_create_index(Config :: term(), HarvesterId :: od_harvester:id(), 
  +-spec harvester_create_index(Config :: term(), HarvesterId :: od_harvester:id(),
       Data :: map()) -> ok.
   harvester_create_index(Config, HarvesterId, Data) ->
       ?assertMatch({ok, _}, call_oz(
  
positive.code:     test_utils:mock_expect(Nodes, PluginName, type, fun() -> harvester_plugin end),
      test_utils:mock_expect(Nodes, PluginName, ping,
          fun(?HARVESTER_ENDPOINT1) -> ok;
             (?HARVESTER_ENDPOINT2) -> ok;
             (_) -> ?ERROR_TEMPORARY_FAILURE
          end),
      test_utils:mock_expect(Nodes, PluginName, submit_batch, fun(_,HarvesterId,Indices, Batch) ->
          FirstSeq = maps:get(<<"seq">>, lists:nth(1, Batch)),
          {LastSeq, ErrorSeq} = lists:foldl(
              fun(BatchEntry, {A, undefined}) ->
  
negative.code: %%--------------------------------------------------------------------
  overwrite_compatibility_registry(TestConfig, Registry) ->
      {ok, RegistryPath} = call_oz(TestConfig, application, get_env, [ctool, compatibility_registry_path]),
      {ok, DefaultRegistryPath} = call_oz(TestConfig, application, get_env, [ctool, default_compatibility_registry]),
      rpc:multicall(?OZ_NODES(TestConfig), file, write_file, [RegistryPath, json_utils:encode(Registry)]),
      rpc:multicall(?OZ_NODES(TestConfig), file, write_file, [DefaultRegistryPath, json_utils:encode(Registry)]),
      rpc:multicall(?OZ_NODES(TestConfig), compatibility, clear_registry_cache, []),
      ok.
  
  