o qmiJ@sddlZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZd d lmZmZd dlmZmZeejdZGdddZGdddZdS)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)BulkJobCallbackParams)(SpeechToTextTranslateJobParametersParams)BulkJobInitResponseV1)FilesDownloadResponse)FilesUploadResponse)JobStatusV1Response)SpeechToTextTranslateModel)&AsyncRawSpeechToTextTranslateJobClient!RawSpeechToTextTranslateJobClient)AsyncSpeechToTextTranslateJobSpeechToTextTranslateJob.c@seZdZdefddZedefddZdeddd e d e j e d e j e d e j edef d dZddded e j edefddZdddded e j e d e j edefddZddddede jed e j e d e j edef ddZddddede jed e j e d e j edef ddZddddedfdedede j ed e j e d e j e d e j edefd!d"Zdedefd#d$ZdS)%SpeechToTextTranslateJobClientclient_wrappercCt|d|_dSN)r)r _raw_clientselfrr`/home/ubuntu/.local/lib/python3.10/site-packages/sarvamai/speech_to_text_translate_job/client.py__init__z'SpeechToTextTranslateJobClient.__init__returncC|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawSpeechToTextTranslateJobClient rrrrrwith_raw_response z0SpeechToTextTranslateJobClient.with_raw_responseNptu_idcallbackrequest_optionsjob_parametersr$r%r&cC|jj||||d}|jS)aX Get a job uuid, and storage folder details for speech to text tranlsate bulk job v1 Parameters ---------- job_parameters : SpeechToTextTranslateJobParametersParams Job Parameters for the bulk job ptu_id : typing.Optional[int] callback : typing.Optional[BulkJobCallbackParams] Parameters for callback URL request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BulkJobInitResponseV1 Successful Response Examples -------- from sarvamai import SarvamAI client = SarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) client.speech_to_text_translate_job.initialise( job_parameters={}, ) r'r$r%r&r initialisedatarr'r$r%r& _responserrrr+$s(z)SpeechToTextTranslateJobClient.initialiser&job_idcCs|jj||d}|jS)a Get the status of a speech to text translate bulk job V1 Parameters ---------- job_id : str The unique identifier of the job request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- JobStatusV1Response Successful Response Examples -------- from sarvamai import SarvamAI client = SarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) client.speech_to_text_translate_job.get_status( job_id="job_id", ) r/r get_statusr,rr0r&r.rrrr2Qsz)SpeechToTextTranslateJobClient.get_statusr$r&cCs|jj|||d}|jS)a Start a speech to text translate bulk job V1 Parameters ---------- job_id : str The unique identifier of the job ptu_id : typing.Optional[int] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- JobStatusV1Response Successful Response Examples -------- from sarvamai import SarvamAI client = SarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) client.speech_to_text_translate_job.start( job_id="job_id", ) r4rstartr,rr0r$r&r.rrrr6rs$z$SpeechToTextTranslateJobClient.startfilescCr()a Start a speech to text bulk job V1 Parameters ---------- job_id : str files : typing.Sequence[str] ptu_id : typing.Optional[int] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FilesUploadResponse Successful Response Examples -------- from sarvamai import SarvamAI client = SarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) client.speech_to_text_translate_job.get_upload_links( job_id="job_id", files=["files"], ) r0r8r$r&rget_upload_linksr,rr0r8r$r&r.rrrr;'z/SpeechToTextTranslateJobClient.get_upload_linkscCr()a Start a speech to text bulk job V1 Parameters ---------- job_id : str files : typing.Sequence[str] ptu_id : typing.Optional[int] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FilesDownloadResponse Successful Response Examples -------- from sarvamai import SarvamAI client = SarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) client.speech_to_text_translate_job.get_download_links( job_id="job_id", files=["files"], ) r9rget_download_linksr,r<rrrr?r=z1SpeechToTextTranslateJobClient.get_download_links saaras:v2.5Fmodelwith_diarizationprompt num_speakerscCs*|jt||||d||d}t|j|dS)aZ Create a new Speech-to-Text-Translate bulk job. Parameters ---------- model : typing.Optional[SpeechToTextTranslateModel], default="saaras:v2.5" The model to use for speech-to-text translation. with_diarization : typing.Optional[bool], default=False Whether to enable speaker diarization (i.e., distinguishing who is speaking). prompt : typing.Optional[str], default=None An optional prompt to guide the transcription and translation model. num_speakers : typing.Optional[int], default=None The number of distinct speakers in the input audio, if known. callback : typing.Optional[BulkJobCallbackParams], default=OMIT Optional callback configuration to receive job completion events via webhook. request_options : typing.Optional[RequestOptions], default=None Optional configuration for request timeout, retries, etc. Returns ------- SpeechToTextTranslateJob A handle to the newly created Speech-to-Text-Translate job. rCrArBrDr'r%r&r0client)r+rrr0rrArBrCrDr%r&responserrr create_jobs% z)SpeechToTextTranslateJobClient.create_jobcCs t||dS)am Get an existing Speech-to-Text-Translate job handle by job ID. Parameters ---------- job_id : str The job ID of the previously created Speech-to-Text-Translate job. Returns ------- SpeechToTextTranslateJob A job handle which can be used to check status or retrieve results. rG)rrr0rrrget_job"s z&SpeechToTextTranslateJobClient.get_job)__name__ __module__ __qualname__rrpropertyrr!OMITrtypingOptionalintrrrr+strr r2r6Sequencer r;r r?r boolrrKrMrrrrrs . % , 1 . 1rc@seZdZdefddZedefddZdeddd e d e j e d e j e d e j edef d dZddded e j edefddZdddded e j e d e j edefddZddddede jed e j e d e j edef ddZddddede jed e j e d e j edef ddZddddedfdedede j ed e j e d e j e d e j edd!fd"d#Zdedd!fd$d%ZdS)&#AsyncSpeechToTextTranslateJobClientrcCrr)rrrrrrr5rz,AsyncSpeechToTextTranslateJobClient.__init__rcCr)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawSpeechToTextTranslateJobClient rr rrrr!8r"z5AsyncSpeechToTextTranslateJobClient.with_raw_responseNr#r'r$r%r&c"|jj||||dIdH}|jS)a Get a job uuid, and storage folder details for speech to text tranlsate bulk job v1 Parameters ---------- job_parameters : SpeechToTextTranslateJobParametersParams Job Parameters for the bulk job ptu_id : typing.Optional[int] callback : typing.Optional[BulkJobCallbackParams] Parameters for callback URL request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- BulkJobInitResponseV1 Successful Response Examples -------- import asyncio from sarvamai import AsyncSarvamAI client = AsyncSarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) async def main() -> None: await client.speech_to_text_translate_job.initialise( job_parameters={}, ) asyncio.run(main()) r)Nr*r-rrrr+Cs 0 z.AsyncSpeechToTextTranslateJobClient.initialiser/r0cs|jj||dIdH}|jS)a Get the status of a speech to text translate bulk job V1 Parameters ---------- job_id : str The unique identifier of the job request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- JobStatusV1Response Successful Response Examples -------- import asyncio from sarvamai import AsyncSarvamAI client = AsyncSarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) async def main() -> None: await client.speech_to_text_translate_job.get_status( job_id="job_id", ) asyncio.run(main()) r/Nr1r3rrrr2xs&z.AsyncSpeechToTextTranslateJobClient.get_statusr4cs |jj|||dIdH}|jS)a Start a speech to text translate bulk job V1 Parameters ---------- job_id : str The unique identifier of the job ptu_id : typing.Optional[int] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- JobStatusV1Response Successful Response Examples -------- import asyncio from sarvamai import AsyncSarvamAI client = AsyncSarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) async def main() -> None: await client.speech_to_text_translate_job.start( job_id="job_id", ) asyncio.run(main()) r4Nr5r7rrrr6s,z)AsyncSpeechToTextTranslateJobClient.startr8crZ)a* Start a speech to text bulk job V1 Parameters ---------- job_id : str files : typing.Sequence[str] ptu_id : typing.Optional[int] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FilesUploadResponse Successful Response Examples -------- import asyncio from sarvamai import AsyncSarvamAI client = AsyncSarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) async def main() -> None: await client.speech_to_text_translate_job.get_upload_links( job_id="job_id", files=["files"], ) asyncio.run(main()) r9Nr:r<rrrr; / z4AsyncSpeechToTextTranslateJobClient.get_upload_linkscrZ)a. Start a speech to text bulk job V1 Parameters ---------- job_id : str files : typing.Sequence[str] ptu_id : typing.Optional[int] request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- FilesDownloadResponse Successful Response Examples -------- import asyncio from sarvamai import AsyncSarvamAI client = AsyncSarvamAI( api_subscription_key="YOUR_API_SUBSCRIPTION_KEY", ) async def main() -> None: await client.speech_to_text_translate_job.get_download_links( job_id="job_id", files=["files"], ) asyncio.run(main()) r9Nr>r<rrrr?r[z6AsyncSpeechToTextTranslateJobClient.get_download_linksr@FrArBrCrDrcs2|jt||||d||dIdH}t|j|dS)aN Create a new Speech-to-Text-Translate bulk job. Parameters ---------- model : typing.Optional[SpeechToTextTranslateModel], default="saaras:v2.5" The model to use for speech-to-text translation. with_diarization : typing.Optional[bool], default=False Whether to enable speaker diarization (i.e., distinguishing who is speaking). prompt : typing.Optional[str], default=None An optional prompt to guide the transcription and translation model. num_speakers : typing.Optional[int], default=None The number of distinct speakers in the input audio, if known. callback : typing.Optional[BulkJobCallbackParams], default=OMIT Optional callback configuration to receive job completion events via webhook. request_options : typing.Optional[RequestOptions], default=None Optional configuration for request timeout, retries, etc. Returns ------- AsyncSpeechToTextTranslateJob A handle to the newly created job. rErFNrG)r+rrr0rIrrrrK8s%  z.AsyncSpeechToTextTranslateJobClient.create_jobcst||dS)ar Get an existing Speech-to-Text-Translate job handle by job ID. Parameters ---------- job_id : str The job ID of the previously created speech-to-text-translate job. Returns ------- AsyncSpeechToTextTranslateJob A job handle which can be used to check status or retrieve results. rG)rrLrrrrMis z+AsyncSpeechToTextTranslateJobClient.get_job)rNrOrPrrrQrr!rRrrSrTrUrrrr+rVr r2r6rWr r;r r?r rXrKrMrrrrrY4s 6 - 4 9 6 1rY)rScore.client_wrapperrrcore.request_optionsrrequests.bulk_job_callbackr0requests.speech_to_text_translate_job_parametersr types.bulk_job_init_response_v_1rtypes.files_download_responser types.files_upload_responser types.job_status_v_1_responser $types.speech_to_text_translate_modelr raw_clientrrjobrrcastAnyrRrrYrrrrs"        !