0Fie JddlmZddlmZmZddlmZGddeZdS)) annotations)CounterMetricFamilyGaugeMetricFamily)PrometheusCollectorc$eZdZfdZdZxZS)SemaphoreMetricCollectorcXt|d|_dS)N semaphore)super__init__ subsystem)selfserver __class__s Olib/python3.11/site-packages/distributed/http/scheduler/prometheus/semaphore.pyr z!SemaphoreMetricCollector.__init__ s&    $c#XK |jjd}n#t$rYdSwxYwt|dddg}t|dddg}t|dd dg}t |d d dg}t |d d dg}t|dddgd}|jD]\}} ||g| ||gt|j |||g|j d|||g|j d |||g|j d |||g|j d||V|V|V|V|V|VdS)N semaphores max_leaseszhMaximum leases allowed per semaphore Note: This will be constant for each semaphore during its lifetime.name)labels active_leasesz/Amount of currently active leases per semaphorepending_leasesz0Amount of currently pending leases per semaphore acquire_totalz-Total number of leases acquired per semaphore release_totalzTotal number of leases released per semaphore Note: If a semaphore is closed while there are still leases active, this count will not equal `semaphore_acquired_total` after execution.average_pending_lease_timeaExponential moving average of the time it took to acquire a lease per semaphore Note: This only includes time spent on scheduler side, it does not include time spent on communication. Note: This average is calculated based on order of leases instead of time of lease acquisition.s)runitpending) r extensionsKeyErrorr build_namerritems add_metriclenleasesmetrics) rsem_extsemaphore_max_leases_familysemaphore_active_leases_familysemaphore_pending_leasessemaphore_acquire_totalsemaphore_release_total$semaphore_average_pending_lease_timesemaphore_namesemaphore_max_leasess rcollectz SemaphoreMetricCollector.collect s k,\:GG    FF &7 OOL ) ) 28 ' ' ' #*; OOO , , =8* * * & $5 OO, - - >8$ $ $  #6 OOO , , ;8# # #  #6 OOO , , T8 # # # 0A OO8 9 9 , 8 0 0 0 ,5<4F4L4L4N4N   0N0 ' 2 2 "6    + 5 5 #gn^&D"E"E    % / / '/)"<^"L    $ . . '//"B>"R    $ . . '//"B>"R    1 ; ;  <=nM    *))),,,,&&&&%%%%%%%%222222s  %%)__name__ __module__ __qualname__r r1 __classcell__)rs@rrrsN%%%%%J3J3J3J3J3J3J3rrN) __future__rprometheus_client.corerrdistributed.http.prometheusrrrrr:s""""""IIIIIIII;;;;;;O3O3O3O3O32O3O3O3O3O3r