ڰj, :SrSSKrSSKrSSKrSSKrSSKJrJrJrJ r J r J r J r SSK r SSKJrJr SSKJr SSKJr SS KJr S S KJr S S KJrJr S S KJr S SKJ r J!r!J"r" \#"\RHRKS55RMS\ 5r'\"5r(\""5r)S\ \#4Sjr*S\S\ \#4Sjr+SS\,4Sjjr-SS\S\,S\ \ \ \#\44Sjjr.S\S\ \#\4S\/4Sjr0S\S\ \#\4S\ \#\44Sjr1S\S\ \#\4S\\ \#\ \#\44S44Sjr2g) z Job related helpers. N)AnyAsyncGeneratorCallableDictOptionalUnionList) ClientSessionTooManyRequests) RunPodLogger) __version__) rp_debugger) is_generator) send_result stream_result)check_return_size) WORKER_IDREF_COUNT_ZERO JobsProgressRUNPOD_WEBHOOK_GET_JOBz$IDreturncDS[;ag[RSS5$)z Prepare the URL for the worker's dedicated stop channel. Derived from the job-take URL so it points at the same endpoint and worker, preserving its query string (auth and routing params). Returns None when the job-take URL is not in the expected form. /job-take/Nz /job-stop/) JOB_GET_URLreplace]/home/mande/repo/quber/.venv/lib/python3.13/site-packages/runpod/serverless/modules/rp_job.py _job_stop_urlr"s";&   |\ ::r sessionc# [5nU(d/$URU5IShvN nURS:Xa/sSSS5IShvN $URS:Xa4[URUR URUR S9eUR5 URS:wa5[RSUR35 /sSSS5IShvN $UR5IShvN n[U[ 5(d>[RS[#U5R$35 /sSSS5IShvN $URS /5n[U[&5(d>[RS [#U5R$35 /sSSS5IShvN $UVs/sHn[U[(5(dMUPM nn[+U5[+U5:wa.[RS [+U5[+U5- S 35 UsSSS5IShvN $GNGNGN_GNH![R[4a6n[RSU35 /sSnAsSSS5IShvN $SnAff=fGNLNs snfNn!,IShvN (df  g=f7f) ap Long-poll the dedicated stop channel for request ids the worker should stop. The server is expected to hold the request open (long-poll) until a stop signal is available or the poll times out, so cancellations and timeouts reach the worker without waiting for the next heartbeat. Returns: A list of request ids to stop. Empty when the poll returned no signals. Nstatusmessageapplication/jsonz4rp_job | get_stop_signals: unexpected content type: z5rp_job | get_stop_signals: failed to parse response: z4rp_job | get_stop_signals: unexpected payload type: jobsToStopz5rp_job | get_stop_signals: jobsToStop is not a list: z#rp_job | get_stop_signals: dropped z non-string job ids)r"getr(r request_infohistoryreasonraise_for_status content_typelogwarnjsonaiohttpContentTypeError ValueError isinstancedicttype__name__liststrlen)r#stop_urlresponsepayloaderrorraw_idsjob_idjob_idss r!get_stop_signalsrF*s5H  {{8$$ ??c !%$$ ??c !!%%      !!#  $6 6 HHFxG\G\F]^ %%$$( $MMO+G '4(( HHFtG}G]G]F^_ =%$$@++lB/'4(( HHGW H^H^G_` K%$$N)0Kf:fc3J6K w<3w< ' HH5c'lS\6Q5RRef Y%$$$*,((*5  HHLUGT UI1%$$, -%NLO%$$$s&)KH?KJ* K IKBJ* K&I'K-I II AJ* KJKAJ*+ K7J!8K=J*J#J#$A J*- K9J(:KKKI  J%J>J?J* KJKJJ*K!K#J*(K*K0J3 1 K=K batch_sizecUS:a[RSS5nUSU3- nO[n[R5(aSOSnUSU3- n[R SU35 U$) aH Prepare the URL for making a 'get' request to the serverless API (sls). This function constructs the appropriate URL for sending a 'get' request to the serverless API, ensuring that the request will be correctly routed and processed by the API. Returns: str: The prepared URL for the 'get' request to the serverless API. rrz/job-take-batch/z &batch_size=10z&job_in_progress=zrp_job | get_job: )rr job_progress get_job_listr2debug)rG job_take_urljob_in_progresss r! _job_get_urlrPhsvA~"**<9KL ,zl33 " )6688ccO''899LII"<.12 r num_jobsc# UR[U55IShvN n[RS[ U5R SUR 35 UR S:Xa'[RS5 SSS5IShvN gUR S:Xa'[RS5 SSS5IShvN gUR S:Xa4[URURUR URS 9eUR5 URS :wa4[RS UR35 SSS5IShvN gURS :Xa'[RS 5 SSS5IShvN gUR5IShvN n[RS5 ['U[(5(a+SU;dSU;a [+S5eU/sSSS5IShvN $['U[,5(aUsSSS5IShvN $SSS5IShvN gGN!GNGNNNN![R a6 [RSUR"35 SSS5IShvN g[$a3n[RSU35 SnASSS5IShvN gSnAff=fNNN!,IShvN (df  g=f7f)a Get a job from the job-take API. `num_jobs = 1` will query the legacy singular job-take API. `num_jobs > 1` will query the batch job-take API. Args: session (ClientSession): The aiohttp ClientSession to use for the request. num_jobs (int): The number of jobs to get. Nzrp_job | Response:  r%z&rp_job | Received 204 status, no jobs.izArp_job | Received 400 status, expected when FlashBoot is enabled.r&r'r*z"rp_job | Unexpected content type: rzrp_job | No content to parse.zrp_job | Received Job(s)z-rp_job | Response content is not valid JSON. z(rp_job | Failed to parse JSON response: idinputz&Job has missing field(s): id or input.)r,rPr2rMr:r;r(r r-r.r/r0r1content_lengthr4r5r6contentr7r8r9 Exceptionr<)r#rQr@jobs json_errors r!get_jobr[sM{{<122h 'X(?(?'@(//ARST ??c ! II> ?  322 ??c ! IIY Z 322 ??c !!%%      !!#  $6 6 II:8;P;P:QR S 33228  " "a ' II5 6 =322@ !(D II0 1 dD ! !47$#6 HII6]322b dD ! !e322222B)''  IIEhFVFVEWX Y K322L  II@ M N Q322L M3222sTK9IK9AK K9IK9&K; K9IK9 BK K9I K9$&K K9I K9I/I0I .K7 K9KK9 K K9+K,K9<K=K9K9K9 K9 K9I6KK K9JK9 K#K;K? K9 K  K9KKK9K9K9K6%K( & K62K9configc# [US5(GaSn[USU5n[RSUS5 S/0nUShvN n[RSU3US5 [ UR S5[ 5(a,USR S5(aS[USS50nUR S5(aUn O]UR SS 5(aUSRUS5 [XU5IShvN MS n[USU5IShvN nUR S S 5(a[RS US5 SUS 'UR S 05R SS 5(ac[ U[ 5(aN[R"5USS'[RSUS5 US[- S-nXuSSS'O.[RSUS5 [R"5 [!XX#S9IShvN gGNGN# GN GNN7f)NhandlerTz*Handler is a generator, streaming results.rToutputzStream output: rBreturn_aggregate_streamFrefresh_workerz0refresh_worker flag set, stopping pod after job.stopPodrp_argsrz2rp_debugger | Flag set, returning debugger output.reference_counter_startiready_delay_msz5rp_debugger | Flag not set, skipping debugger output.) is_stream)rrun_job_generatorr2rMr8r,r9r=appendrrun_jobinforget_debugger_outputrclear_debugger_outputr)r#r\jobrfgenerator_output job_result stream_output ready_delays r! handle_jobrrsF9%&& ,VI->D >D J^ #3 =- II 7T C-++H5t<< *..w77%,c-2I'2R.S$TM  ))* zz3U;;8$++M(,CD< < < "6)#4c:: zz"E** CSYO $ 9zz)R $$]E::z*VZ?[?[.9.M.M.O 8]+ FD R78>ITQ @K8]+,<= I3t9U))+ g3 DDDK = =$4";(Es\AIH9 H3 H9CIH6I.H</C>I-H?.I3H96I9I?Ir^rmc p# [RSUS5 0nU"U5n[R"U5(a UIShvN OUn[R SU3US5 [ U[ 5(a@URSS5nURSS5nXBS'U(aXRS'U(aSUS 'O[ U[5(aSU0nOSU0nURS50:XaURS5 [U5 [R SU3US5 U$N![an[[U55[U5[R"5[ R"RS S 5[ R"RS S 5[$S .n[R'SUS5 [R'[(R*"USS95 S[(R*"U50nSnANSnAff=f![R SU3US5 f=f7f)z Run the job using the handler. Args: handler (Callable): The handler function to use. job (Dict[str, Any]): The job to run. Returns: Dict[str, Any]: The result of running the job. zStarted.rTNzHandler output: rBrar_TrbRUNPOD_POD_HOSTNAMEunknown RUNPOD_POD_ID) error_type error_messageerror_tracebackhostname worker_idrunpod_versionzCaptured Handler Exception)indentzrun_job return: )r2rjinspect isawaitablerMr8r9popboolr,rrXr=r: traceback format_excosenvironr|rBr4dumps) r^rm run_resulthandler_return job_output error_msgraerr error_infos r!ririsHHZT#J.> "">22!   $ZL13t9= j$ ' '"w5I'^^,>( #r ) NN8 $*%" $ZL13t9= [ !8  7d3i. X(335 '?TK00#- .D : 1  V #4y!)CH:^Irsr MMM=<4$/&AA"**..!9:;CCE9U n~  ;x} ;;M;d3i;|S2-.@ @&)@ d4S>"#@F,Em,ET#s(^,ET,E^>8>$sCx.>T#s(^>B; ; cN;DeCHo-.45;r