async def METHOD_NAME(self, async_client, docs_count, **kwargs):
    # get input params
    variables = kwargs.pop('variables', {})
    wait_for_operation = kwargs.pop('wait', False)
    language = kwargs.pop('language', "es")
    # prepare containers and test data
    blob_data = Document.create_dummy_docs(docs_count=docs_count)
    source_container_sas_url = self.create_source_container(data=blob_data, variables=variables)
    target_container_sas_url = self.create_target_container(variables=variables)
    # prepare translation inputs
    translation_inputs = [
        DocumentTranslationInput(
            source_url=source_container_sas_url,
            targets=[
                TranslationTarget(
                    target_url=target_container_sas_url,
                    language=language
                )
            ]
        )
    ]
    # submit operation
    poller = await async_client.begin_translation(translation_inputs)
    assert poller.id is not None
    # wait for result
    if wait_for_operation:
        result = await poller.result()
        async for doc in result:
            self._validate_doc_status(doc, "es")
    # validate
    self._validate_translation_metadata(poller=poller)
    return poller