ڰj2SrSSKrSSKrSSKJrJr SSKJrJrJ r J r SSK J r \R"5r\ R"5rS\4SjrS\\\4SS4S jrS\\\4SS4S jrg) zz runpod | serverless | worker_loop.py Called to convert a container into a worker pod for the runpod serverless platform. N)AnyDict) rp_loggerrp_localrp_pingrp_scale)run_fitness_checksreturnc~USRSS5(ag[RRSS5cgg)z?Returns True if the worker is running locally, False otherwise.rp_args test_inputNTRUNPOD_WEBHOOK_GET_JOBF)getosenvironconfigs U/home/mande/repo/quber/.venv/lib/python3.13/site-packages/runpod/serverless/worker.py _is_localrs9 i\400 zz~~.5= rc[R"[55 SSKJnJn U"5nU"5R U5 [RU5 [R"U5nUR5 g)a  Starts the worker loop for multi-processing. This function is called when the worker is running on Runpod. This function starts a loop that runs indefinitely until the worker is killed. Args: config (Dict[str, Any]): Configuration parameters for the worker. r) JobsProgress PingJobMirrorN) asynciorunr &runpod.serverless.modules.worker_staterr set_mirror heartbeat start_pingr JobScalerstart)rrrmirror job_scalers r run_workerr$s_ KK"$%S _FNf% ##F+Jrc[U5(a+[R"[R"U55 g[ U5 g)z Checks if the worker is running locally or on Runpod. If running locally, the test job is run and the worker exits. If running on Runpod, the worker loop is created. N)rrrr run_localr$rs rmainr'8s0  H&&v./ 6r)__doc__rrtypingrrrunpod.serverless.modulesrrrr$runpod.serverless.modules.rp_fitnessr RunPodLoggerlog Heartbeatrboolrstrr$r'rrr2s|  LLC     tCH~$6 c3h D r