def METHOD_NAME(self, partition_key_target_range):
    rewritten_query = self._partitioned_query_ex_info.get_rewritten_query()
    if rewritten_query:
        if isinstance(self._query, dict):
            # this is a parameterized query, collect all the parameters
            query = dict(self._query)
            query["query"] = rewritten_query
        else:
            query = rewritten_query
    else:
        query = self._query
    return document_producer._DocumentProducer(
        partition_key_target_range,
        self._client,
        self._resource_link,
        query,
        self._document_producer_comparator,
        self._options,
    )