o Á¿i»ã@s<ddlZddlmZddlmZeeƒZGdd„deƒZdS)éN)ÚOptionalé)Ú get_loggerc @sÀeZdZUdZdZdZgZeee d<dZ eeeeefe d<dZ ddeedeedeeed dfd d„Zdd „Zdd„Zddeeed eeeeeffdd„Zdd„ZdS)ÚValueCollectorauA basic state machine useful for collecting, caching and updating data obtained from different Python modules. The two primary use-cases are 1) data loaded once (like tagging information) 2) periodically updating data sources (like thread count) Functionality is provided for requiring and importing modules which may or may not be installed. TFÚrequired_modulesNÚvalueÚenabledÚperiodicÚreturncCsb|dur|jn||_|dur|jn||_|dur|jn||_d|_| ¡|_|jr/| ¡dSdS)NF)rr rÚ_modules_successfully_loadedÚ _load_modulesÚmodulesÚ_on_modules_load)Úselfrr r©rúV/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/runtime/collector.pyÚ__init__s ÿzValueCollector.__init__cCsdS)zHHook triggered after all required_modules have been successfully loaded.Nr©rrrrr+szValueCollector._on_modules_loadcCsTi}z|jD] }t |¡||<qd|_W|Sty)d|_t d||¡YdSw)NTFz9Could not import module "%s" for %s. Disabling collector.)rÚ importlibÚ import_modulerÚImportErrorrÚlogÚwarning)rr Úmodulerrrr.s ûüzValueCollector._load_modulesÚkeyscsn|js|jSˆp tƒ‰|js|jr|jS| ˆ¡|_tˆƒdkr1t|jtƒr1‡fdd„|jDƒ|_d|_|jS)zpReturns metrics as collected by `collect_fn`. :param keys: The keys of the metrics to collect. rcs g|]\}}|ˆvr||f‘qSrr)Ú.0ÚkÚv©rrrÚ Ns z*ValueCollector.collect..T) rrÚsetr Úvalue_loadedÚ collect_fnÚlenÚ isinstanceÚlist)rrrrrÚcollect;s zValueCollector.collectcCsd |jj|j|j|j¡S)Nz0<{}(enabled={},periodic={},required_modules={})>)ÚformatÚ __class__Ú__name__rr rrrrrÚ__repr__SsüzValueCollector.__repr__)NNN)N)r)Ú __module__Ú__qualname__Ú__doc__rr rr%ÚstrÚ__annotations__rrÚtupler!Úboolrrrr r&r*rrrrr s. üþý ü û, r) rÚtypingrÚloggerrr)rÚobjectrrrrrÚs