@distributed_trace_async
async def test_four(self, input: Optional[Union[(IO, '_models.SourcePath')]]=None, **kwargs: Any) -> None:
    'TestFour should be in OperationGroupTwoOperations.\n\n        :param input: Input parameter.\n        :type input: IO or ~multiapi.v3.models.SourcePath\n        :keyword str content_type: Media type of the body sent to the API. Default value is\n         "application/json". Allowed values are: "application/pdf", "image/jpeg", "image/png",\n         "image/tiff", "application/json."\n        :keyword callable cls: A custom type or function that will be passed the direct response\n        :return: None, or the result of cls(response)\n        :rtype: None\n        :raises: ~azure.core.exceptions.HttpResponseError\n        '
    cls = kwargs.pop('cls', None)
    error_map = {401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError}
    error_map.update(kwargs.pop('error_map', {}))
    content_type = kwargs.pop('content_type', 'application/json')
    _json = None
    _content = None
    if (content_type.split(';')[0] in ['application/json']):
        if (input is not None):
            _json = self._serialize.body(input, 'SourcePath')
    elif (content_type.split(';')[0] in ['application/pdf', 'image/jpeg', 'image/png', 'image/tiff']):
        _content = input
    else:
        raise ValueError("The content_type '{}' is not one of the allowed values: ['application/pdf', 'image/jpeg', 'image/png', 'image/tiff', 'application/json']".format(content_type))
    request = build_test_four_request(content_type=content_type, json=_json, content=_content, template_url=self.test_four.metadata['url'])
    request = _convert_request(request)
    request.url = self._client.format_url(request.url)
    pipeline_response = (await self._client._pipeline.run(request, stream=False, **kwargs))
    response = pipeline_response.http_response
    if (response.status_code not in [200]):
        map_error(status_code=response.status_code, response=response, error_map=error_map)
        error = self._deserialize.failsafe_deserialize(_models.Error, pipeline_response)
        raise HttpResponseError(response=response, model=error, error_format=ARMErrorFormat)
    if cls:
        return cls(pipeline_response, None, {})
TestFour should be in OperationGroupTwoOperations.

:param input: Input parameter.
:type input: IO or ~multiapi.v3.models.SourcePath
:keyword str content_type: Media type of the body sent to the API. Default value is
 "application/json". Allowed values are: "application/pdf", "image/jpeg", "image/png",
 "image/tiff", "application/json."
:keyword callable cls: A custom type or function that will be passed the direct response
:return: None, or the result of cls(response)
:rtype: None
:raises: ~azure.core.exceptions.HttpResponseError
@distributed_trace_async
async def test_four(self, input: Optional[Union[(IO, '_models.SourcePath')]]=None, **kwargs: Any) -> None:
    'TestFour should be in OperationGroupTwoOperations.\n\n        :param input: Input parameter.\n        :type input: IO or ~multiapi.v3.models.SourcePath\n        :keyword str content_type: Media type of the body sent to the API. Default value is\n         "application/json". Allowed values are: "application/pdf", "image/jpeg", "image/png",\n         "image/tiff", "application/json."\n        :keyword callable cls: A custom type or function that will be passed the direct response\n        :return: None, or the result of cls(response)\n        :rtype: None\n        :raises: ~azure.core.exceptions.HttpResponseError\n        '
    cls = kwargs.pop('cls', None)
    error_map = {401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError}
    error_map.update(kwargs.pop('error_map', {}))
    content_type = kwargs.pop('content_type', 'application/json')
    _json = None
    _content = None
    if (content_type.split(';')[0] in ['application/json']):
        if (input is not None):
            _json = self._serialize.body(input, 'SourcePath')
    elif (content_type.split(';')[0] in ['application/pdf', 'image/jpeg', 'image/png', 'image/tiff']):
        _content = input
    else:
        raise ValueError("The content_type '{}' is not one of the allowed values: ['application/pdf', 'image/jpeg', 'image/png', 'image/tiff', 'application/json']".format(content_type))
    request = build_test_four_request(content_type=content_type, json=_json, content=_content, template_url=self.test_four.metadata['url'])
    request = _convert_request(request)
    request.url = self._client.format_url(request.url)
    pipeline_response = (await self._client._pipeline.run(request, stream=False, **kwargs))
    response = pipeline_response.http_response
    if (response.status_code not in [200]):
        map_error(status_code=response.status_code, response=response, error_map=error_map)
        error = self._deserialize.failsafe_deserialize(_models.Error, pipeline_response)
        raise HttpResponseError(response=response, model=error, error_format=ARMErrorFormat)
    if cls:
        return cls(pipeline_response, None, {})