ڰjSrSSKrSSKrSSKJr SSKrSSKJr SSKJ r SSK J r SSK J r SSKJr \ "5r"S S 5rg) zx This module defines the Heartbeat class. The heartbeat is responsible for sending periodic pings to the Runpod server. N)Process)Retry)SyncClientSession) RunPodLogger) WORKER_ID) __version__cX\rSrSrSrSrS S Sjjr\S Sj5rS Sjr SSjr S r S r g) Heartbeatz&Sends heartbeats to the Runpod server.FNc|[RRSS5UlURR S[ 5Ul[ [RRSS55S-UlSUl[5Ul URRRS[RRS S 505 [U/S QS /S S9n[RR!UUUS9nURR#SU5 URR#SU5 g)z" Initializes the Heartbeat class. RUNPOD_WEBHOOK_PING PING_NOT_SETz$RUNPOD_POD_IDRUNPOD_PING_INTERVALi'iN AuthorizationRUNPOD_AI_API_KEY)iiiiiGET)totalstatus_forcelistallowed_methodsbackoff_factor)pool_connections pool_maxsize max_retrieszhttp://zhttps://)osenvirongetPING_URLreplacerint PING_INTERVAL_mirrorr_sessionheadersupdaterrequestsadapters HTTPAdaptermount)selfrretriesretry_strategyadapters ^/home/mande/repo/quber/.venv/lib/python3.13/site-packages/runpod/serverless/modules/rp_ping.py__init__Heartbeat.__init__s ' J  0F!NOSWW *+  $$ bjjnn-@"E F 6"G  ##//-)&0  Iw/ J0cF[5nXlURU5 g)zv Static helper to run the ping loop in a separate process. Creates a new Heartbeat instance to avoid pickling issues. N)r r# ping_loop)mirrortesthbs r/ process_loopHeartbeat.process_loop9s [  Tr2c[RRS5(d[R S5 g[RRS5(d[R S5 gUR (aUR S:Xa[RS5 g[R(d<[[RX4S9nS Ul UR5 S [l gg) zC Sends heartbeat pings to the Runpod server in a separate process. rz:Not deployed on Runpod serverless, pings will not be sent.N RUNPOD_POD_IDz.Not running on Runpod, pings will not be sent.rz$Ping URL not set, cannot start ping.)targetargsT)rrrlogdebuginforerrorr _process_startedrr8daemonstart)r+r5r6processs r/ start_pingHeartbeat.start_pingCszz~~122 IIR S zz~~o.. HHE F  $-->"A II< = ))Y%;%;6.QG!GN MMO)-I & *r2cxUR5 [R"UR5 U(agM:)z? Sends heartbeat pings to the Runpod server until interrupted. N) _send_pingtimesleepr")r+r6s r/r4Heartbeat.ping_loopYs. OO  JJt)) * r2cURbURR5OSnU[S.nURRURX R S-S9n[ RSURSUR35 g![Ra#n[ RSUS35 SnAgSnAff=f) z) Sends a heartbeat to the Runpod server. N)job_idrunpod_version)paramstimeoutzHeartbeat Sent | URL: z | Status: zPing Request Error: z, attempting to restart ping.) r#rrOr$rr"r>r?url status_coder'RequestExceptionrA)r+job_ids ping_paramsresulterrs r/rIHeartbeat._send_pingcs)- (@$,,""$d!(NK  Q]]&& k;M;MPQ;Q'F II( K@R@R?ST (( Q II,SE1NO P P QsA BC )CC )r"rr#r$) )returnN)NF)F) __name__ __module__ __qualname____firstlineno____doc__rBr0 staticmethodr8rFr4rI__static_attributes__r2r/r r s501@.,Qr2r )rbrrJmultiprocessingrr'urllib3.util.retryrrunpod.http_clientr#runpod.serverless.modules.rp_loggerr&runpod.serverless.modules.worker_staterrunpod.versionrrOr>r rer2r/rls<  #$0<<8n_Q_Qr2