tniuO dZddlZddlZddlZddlmZddlmZmZm Z m Z ddlm Z ddl Z ddl Z ddlmZddlmZddlmZe jGd d e ZGd d e Zd ZdZdZGdde ZdS)z' Tests for runpod | serverless| worker N)mock)patch mock_openMock MagicMock)IsolatedAsyncioTestCase) RunPodLogger)_handle_uncaught_exception)_signal_handlerczeZdZdZdZdZdZdZdZe de dd Z d S) TestWorkerz#Tests for Runpod serverless worker.c`Ktjd|_|jddid|_dS)Ntest) return_value test_input)handlerrp_args)rr mock_handler mock_configselfs ^/var/www/html/gpu-tools/venv/lib/python3.11/site-packages/tests/test_serverless/test_worker.py asyncSetUpzTestWorker.asyncSetUps> I6:::($d+  ctd5}d|jj_tjjdiidusJtjjdddiidusJd|jj_tjj|jdusJ ddddS#1swxYwYdS)z Test _is_local runpod.serverless.worker.osNrTr somethingF renvirongetrrunpod serverlessworker _is_localrrmock_oss r test_is_localzTestWorker.test_is_local s60 1 1 QW/3GO  ,$+55y"oFF$NNNN!(22{ ;< 0;GO  ,$+55d6FGG5PPPPP Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q QsB&CC Cc8tdtd5}|t5tjd|ji|jsJ dddn #1swxYwYddddS#1swxYwYdS)z( Test basic start call. z builtins.openz{"input":{"number":1}}) read_datarN) rr assertRaises SystemExitr!r"startrcalled)r mock_files r test_startzTestWorker.test_start1s" Y1IJJJ   $ ))*55 $ $   # #Y0A$B C C C# # # # #  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s4B0A7+ B7A; ;B>A; ?BBBcPtd5}d|jj_tjj|jdusJd|jj_tjj|jdusJ ddddS#1swxYwYdS)z( Test _is_local_testing rNTrFrr%s rtest_is_local_testingz TestWorker.test_is_local_testing=s0 1 1 QW/3GO  ,$+55d6FGG4OOOO/:GO  ,$+55d6FGG5PPPPP  Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q Q QsA=BB"Bctj}d|_d|_d|_d|_d|_d|_d|_td5}td5}|gf|_ tj d |ji|jsJ dddn #1swxYwYddddS#1swxYwYdS) z+ Test local FastAPI setup. NT@ localhost{"test": "test"}(argparse.ArgumentParser.parse_known_argsz.runpod.serverless.modules.rp_fastapi.WorkerAPIr)argparse Namespace rp_log_level rp_debugger rp_serve_api rp_api_portrp_api_concurrency rp_api_hostrrrr!r"r,rr-)r known_argsmock_parse_known_argsmock_worker_apis rtest_local_apizTestWorker.test_local_apiGsd')) "& !% "& !% () %!,  2   6  * "E <% %  *1;R ! .   # #Y0A$B C C C") ) ) ) ) * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *s6C$9B* C*B. .C1B. 2CC Czrunpod.serverless.logzrunpod.serverless.sys.exitcTtdd|jsJ|jjsJdS)z& Test signal handler. N)r r-info)r mock_exit mock_loggers rtest_signal_handlerzTestWorker.test_signal_handler_s; d###&&&&&&rN) __name__ __module__ __qualname____doc__rr'r/r1rCrrHrrr r s--   QQQ" $ $ $QQQ***0 U "## U '(('')($#'''rr ceZdZdZdZdZdS)TestWorkerTestInput%Tests for runpod | serverless| workerc`Kt|_i|j_d|j_dS)Nr)rrrrs rrzTestWorkerTestInput.asyncSetUpos. FF)+&)/&&&rctj}d|_d|_d|_d|_d|_d|_d|_d|_ td5}| t5|gf|_ tjd |jit%}|jdksJ dddn #1swxYwYddddS#1swxYwYdS) z Test sys args. WARNTNr3r4r5r6r7r)r8r9r:r;r<r=r>r?r test_outputrr*r+rr!r"r,rr level)rr@rAlogs rtest_worker_bad_localz)TestWorkerTestInput.test_worker_bad_localus~')) "( !% "& !% () %!,  2 !3   6  ' "D$5$5j$A$A ' '2   8 S ::::: 8887778sA AAceZdZdZdZdZedededededd Zededededd Zededededd Z ededededd Z edededededd Z edededededdZ ededdZ ededdZedededdZdS) TestRunWorkerrPc\Kdtjd<tddddd|_dS)Nzhttps://test.comRUNPOD_WEBHOOK_GET_JOBTDEBUGr;r:rrefresh_workerr)osrrconfigrs rrzTestRunWorker.asyncSetUps</A +,!{{"'+WEE   rc6Ktjt_dSN)sys__excepthook__ excepthookrs r asyncTearDownzTestRunWorker.asyncTearDowns+rz5runpod.serverless.modules.rp_scale.AsyncClientSessionz*runpod.serverless.modules.rp_scale.get_jobz(runpod.serverless.modules.rp_job.run_jobz.runpod.serverless.modules.rp_job.stream_resultz,runpod.serverless.modules.rp_job.send_resultc0Kdddidggg|_dddii|_tj|j||jd|||j rJ|j sJdS) z)Test run_worker with synchronous handler.123numberr4rdinputrhresultoddN) side_effectrr!r"r,rs assertEqual call_countassert_called_oncer-)rmock_send_resultmock_stream_result mock_run_job mock_get_job mock_sessions rtest_run_workerzTestRunWorker.test_run_workers XqM 2 2 3 $  &.%/@$A !  ,,, 0!444'')))++---%,,,,""""""rcKdddidg|_tdd}tj||jsJ|jrJ|jd\}}}|dgddksJd S) a Test run_worker with generator handler. Args: mock_stream_result (_type_): _description_ mock_run_job_generator (_type_): _description_ mock_run_job (_type_): _description_ mock_get_job (_type_): _description_ z generator-123r|r4r}TrrqrrhstopPodNrr_r!r"r,r- mock_callsrrrrrgenerator_config_argss r!test_run_worker_generator_handlerz/TestRunWorker.test_run_worker_generator_handlers"-,>,>@e,>,>,> f frcKdddidg|_tddd}tj||jsJ|jsJ|jrJ|jd\}}}|ddd gdd ksJd S) aG Test run_worker with generator handler. Args: mock_send_result (_type_): _description_ mock_stream_result (_type_): _description_ mock_run_job (_type_): _description_ mock_get_job (_type_): _description_ mock_session (_type_): _description_ zgenerator-123-aggregater|r4r}T)rreturn_aggregate_streamrqrrZr[rNrrs r+test_run_worker_generator_aggregate_handlerz9TestRunWorker.test_run_worker_generator_aggregate_handler.s&-!} E E% ! )'+"    0111&&&&!((((&&&&&03 4Awgw%7DIIIIIIIIrcKdddidg|_dddii|_d}|j}||d <tj|||jdd |j||jdd |j||jdd |j||j d | |j d|j D]J}|\} } d| dvr$| d| ddd5| dKdS)a Test run_worker with synchronous handler, ensuring that concurrency behavior is respected and that the calls to `get_job`, `run_job`, and `send_result` follow expected patterns. Args: mock_send_result: Mock for send_result function mock_stream_result: Mock for stream_result function mock_run_job: Mock for run_job function mock_get_job: Mock for get_job function mock_session: Mock for AsyncClientSession r{r|r4r}rhrrc|SrurM)current_concurrencys rconcurrency_modifierzGTestRunWorker.test_run_worker_concurrency..concurrency_modifierss& &rrz/Expected at least one call to get_job, but got z/Expected at least one call to run_job, but got z3Expected at least one call to send_result, but got z5stream_result should not be called in this test case.z3Expected the mock_session to be used at least once.z8Expected 'result' to be part of the 'output' dictionary.z@The 'output' key was not found in the arguments for send_result.N)rrscopyr!r"r,assertGreaterEqualr assertFalser- assertTruerassertInfail) rrrrrrrconfig_with_concurrencyrrrs rtest_run_worker_concurrencyz)TestRunWorker.test_run_worker_concurrencyUs4-2XqM%J%J$K !%-%/@$A ! ' ' '#'+"2"2"4"4:N 67  7888   #Q Wl>U W W     #Q Wl>U W W     ' _BRB] _ _     % C      A   %3 ^ ^DLD&47"" d1gh/N  \]]]] ^ ^rc HKdddidg|_dddii|_tj|j||jdd||jdd ||jdd ||jd | |jd td d}tj|| |jdtd5}td d dddddd}||_tj|| |jdt|jddddS#1swxYwYdS)zf Test run_worker with multi-processing enabled for both async and generator handlers. r{r|r4r}rhrrz&Expected at least one call to get_job.z&Expected at least one call to run_job.z*Expected at least one call to send_result.z(Expected stream_result to not be called.z#Expected mock session to be called.Trz>Expected stream_result to be called for the generator handler."runpod.serverless._set_config_argsNr3r5)r;r<r=r>r?rpz'Expected _set_config_args to be called.)rr!r"r,rsrrrr-rr_rrr\r) rrrrrrrmock_set_config_argslimited_configs r test_run_worker_multi_processingz.TestRunWorker.test_run_worker_multi_processings$-2XqM%J%J$K !%-%/@$A !  ,,,  7.mock_is_alives3 +b0C 9 % % % * % % %Jrz5runpod.serverless.modules.rp_scale.JobScaler.is_alive)wrapsN)rrrr!r"r,)rrrrsrrs @r+test_run_worker_multi_processing_scaling_upz9TestRunWorker.test_run_worker_multi_processing_scaling_ups'"-2XqM%J%J$K !%-%/@$A !     &!{{#'+WEE         C=    , ,   # #F + + + , , , , , , , , , , , , , , , , , ,s A;;A?A?zrunpod.serverless.signal.signalz/runpod.serverless.worker.rp_scale.JobScaler.runcrtjitjt ksJdSru)r!r"r,rvrxr )rr__s rtest_start_sets_excepthookz(TestRunWorker.test_start_sets_excepthooks5 ###~!;;;;;;;rz) rsrupdater!r"r,rvrxr )rrrrs r"test_start_does_not_set_excepthookz0TestRunWorker.test_start_does_not_set_excepthook"s{-1K) I &"# ( (       ,,,~!;;;;;;;rN)rIrJrKrLrryrrrrrrrrrrrMrrrkrks//   ,,, U BCC U 788 U 566 U ;<< U 9::##;:=<7698DC #6 U 788 U 566 U ;<< U 9::::;:=<7698:4 U 788 U 566 U ;<< U 9::'f'f;:=<7698'fR U 788 U 566 U ;<< U 9::!J!J;:=<7698!JF U BCC U 788 U 566 U ;<< U 9::F^F^;:=<7698DC F^P U BCC U 788 U 566 U ;<< U 9::8787;:=<7698DC 87t U 788 U 5667,7,76987,r U ,-- U <==<<>=.-< U ,-- U IJJ U /00 < <10KJ.- < < rs-- ;;;;;;;;;;;;,,,,,, <<<<<<IIIIII------ S'S'S'S'S'(S'S'S'l ' ' ' ' '1 ' ' 'F888"|<|<|<|<|<+|<|<|<|<|