anchor.diff:          [] -> InternalParams2;
           [_|_] -> InternalParams2#{
               ?REJECTED_METADATA_KEY => RejectedFields,
  -            <<"__rejection_reason">> => RejectionReason
  +            ?REJECTION_REASON_METADATA_KEY => RejectionReason
           };
  -        all -> InternalParams2#{<<"__rejection_reason">> => RejectionReason}
  +        all -> InternalParams2#{?REJECTION_REASON_METADATA_KEY => RejectionReason}
       end, 
       ResultJson = prepare_json(DecodedJson, RejectedFields),
       ResultJson#{?INTERNAL_METADATA_KEY => InternalParams3}.
  
positive.code: %% Each line ends with literal '\n'
  %% @end
  %%--------------------------------------------------------------------
  -spec prepare_elasticsearch_batch(od_harvester:batch(), rejected_fields()) -> es_batch().
  prepare_elasticsearch_batch(Batch, Rejected) ->
      Requests = lists:map(fun(BatchEntry) ->
          #{
  
negative.code: 
  -define(INTERNAL_METADATA_KEY, <<"__onedata">>).
  -define(REJECTED_METADATA_KEY, <<"__rejected">>).
  -define(REJECTION_REASON_METADATA_KEY, <<"__rejection_reason">>).
  
  -define(MAX_SUBMIT_RETRIES, 3).
  
  