uYf ddlZddlZddlZddlZddlmZGddej ZGddeZ ejd Gd d ej Z y) N)forksafeceZdZdZdZdZy) ServiceStatuszA Service status.stoppedrunningN)__name__ __module__ __qualname____doc__STOPPEDRUNNINGX/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/ddtrace/internal/service.pyrr sGGrrceZdZfdZxZS)ServiceStatusErrorcl||_tt||jd|j y)Nz is already in status )current_statussuperr__init__r value)self service_clsr __class__s rrzServiceStatusError.__init__s1 -  $0,7,@,@.BVBV W r)r r r r __classcell__)rs@rrrs    rrF)eqceZdZdZej ejeddZej e jdddZ dZ dZ dZej dZd Zej d Z d d Zy )Servicez)A service that can be started or stopped.F)defaulttypeinitr)factoryreprr"rc&|j|SN)start)rs r __enter__zService.__enter__%s  rcD|j|jyr&)stopjoin)rexc_type exc_value tracebacks r__exit__zService.__exit__)s  rc|j5|jtjk(r t |j |j|j |i|tj|_dddy#1swYyxYw)zStart the service.N) _service_lockstatusrrrr_start_servicerargskwargss rr'z Service.start-sk   0{{m333(EE D   0 0'//DK  0 0 0 A%A;;Bcy)zStart the service for real. This method uses the internal lock to be sure there's no race conditions and that the service is really started once start() returns. Nrr4s rr3zService._start_service<rc|j5|jtjk(r t |j |j|j |i|tj|_dddy#1swYyxYw)zStop the service.N)r1r2rr rr _stop_servicer4s rr*z Service.stopJsk   0{{m333(EE D   / /'//DK  0 0 0r7cy)zStop the service for real. This method uses the internal lock to be sure there's no race conditions and that the service is really stopped once start() returns. Nrr4s rr;zService._stop_serviceWr9rNcy)zJoin the service once stopped.Nr)rtimeouts rr+z Service.joiner9rr&)r r r r attribrr r2rLockr1r(r/r'abcabstractmethodr3r*r;r+rrrrrs3 TWW]22UW\ ]FDGGHMMEeTM 0      0     -rr) metaclass) rBenumtypingr?rEnumr RuntimeErrorrsABCMetarrrrrLs] DII    5K- K-K-r