ڰj1 SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJ r SSK J r SSK Jr SSKJr SS KJr SS KJr SS KJr /S Qr\"5r\R2"S SS9r\R7S\SSS9 \R7SSSSS9 \R7SSSSS9 \R7S\SSS9 \R7S\SSS9 \R7S\SS S9 \R7S!\SS"S9 S#\4S$jrS#\4S%jr S#\4S&jr!S'r"S(\ \\44S)jr#g)*z Contains the main entrypoint for the Runpod Serverless Worker. Arguments can be passed in when the worker is started, and will be passed to the worker. N)AnyDict) __version__)worker) RunPodLogger)progress_update)register_fitness_check) VolumeCache)startr r runpod_versionr runpodz#Runpod Serverless Worker Arguments.)prog descriptionz--rp_log_levelzrControls what level of logs are printed to the console. Options: ERROR, WARN, INFO, and DEBUG.)typedefaulthelpz --rp_debugger store_truezFlag to enable the Debugger.)actionrrz--rp_serve_apizFlag to start the API server.z --rp_api_porti@z$Port to start the FastAPI server on.z--rp_api_concurrencyz%Number of concurrent FastAPI workers.z --rp_api_host localhostz$Host to start the FastAPI server on.z --test_inputz-Test input for the worker, formatted as JSON.returnc[R5up[RS/U-[l[ U5US'USS(a"[ R "USS5USS'USRSS5(a"[ R "USS5USS'USS(a[RUSS5 U$)z[ Sets the config rp_args, removing any recognized arguments from sys.argv. Returns: config rrp_args test_input test_outputN rp_log_level) parserparse_known_argssysargvvarsjsonloadsgetlog set_level)configargsunknowns W/home/mande/repo/quber/.venv/lib/python3.13/site-packages/runpod/serverless/__init__.py_set_config_argsr,Ws ++-MD }w&CHT F9i&*.**VI5F|5T*Uy,'i]D11+/::fY6G 6V+Wy-(i( fY'78 McT[[RRSS55$)zC Get the realtime port from the environment variable if it exists. RUNPOD_REALTIME_PORT0intosenvironr%r-r+_get_realtime_portr6qs rzz~~4c: ;;r-cT[[RRSS55$)zJ Get the realtime concurrency from the environment variable if it exists. RUNPOD_REALTIME_CONCURRENCY1r1r5r-r+_get_realtime_concurrencyr:xs rzz~~;SA BBr-c^AA[RS5 [R"S5 g)z Handles the SIGINT signal. zSIGINT received. Shutting down.rN)r&infor exit)sigframes r+_signal_handlerr@s! UHH ./HHQKr-r(cb[S[S35 [R"[R[5 [ R "5US'[U5n[5n[5nUSS(aP[RS5 SSK J n URU5nURUSS USS USS S 9 g U(aB[RSUS35 SSK J n URU5nURSUUS 9 g [ R""U5 g )z Starts the serverless worker. config (Dict[str, Any]): Configuration parameters for the worker. config["handler"] (Callable): The handler function to run. config["rp_args"] (Dict[str, Any]): Arguments for the worker, populated by runtime arguments. z*--- Starting Serverless Worker | Version z ---reference_counter_startr rp_serve_apizStarting API server.r) rp_fastapi rp_api_host rp_api_portrp_api_concurrency)api_hostapi_portapi_concurrencyNz)Starting API server for realtime on port .z0.0.0.0)printrsignalSIGINTr@time perf_counterr,r6r:r&r<modulesrD WorkerAPI start_uvicornrmain)r( realtime_portrealtime_concurrencyrD api_servers r+r r s! 6~6Fd KL MM&--1(,(9(9(;F $% f %F&(M46 i( '('))&1   I&}5I&}5"9-.BC !  <]O1MN'))&1   "0 !  KK r-)$__doc__argparser#r3rMr rOtypingrrversionrrrmodules.rp_loggerr modules.rp_progressr modules.rp_fitnessr utils.rp_volume_cacher __all__r&ArgumentParserr add_argumentstrr2dictr,r6r:r@r r5r-r+rfs  3+06. n  D   >    '    (  #t2X 0    /   8 4