uYfddlZddlZddlmZddlmZddlmZddlmZddlm Z ddl m Z eje ZejGdd ej ZejGd d eZy) N)compat)periodic)ddup) _traceback)exporter)configc|eZdZdZej Zej Zej ddZej e e jZ ej dZ ej dddZej ee j j"ZdZfd Zd Zd ZxZS) Schedulerz!Schedule export of recorded data.NF)defaulteq)typer )init)rr r c&|j|_y)N)interval_configured_interval)selfs [/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/ddtrace/profiling/scheduler.py__attrs_post_init__zScheduler.__attrs_post_init__s$(MM!c|jrtjsd|_tj dt t |tj|_ tj dy)zStart the scheduler.FzStarting schedulerzScheduler startedN) _export_libdd_enabledr is_availableLOGdebugsuperr _start_servicertime_ns _last_exportr __class__s rrzScheduler._start_service!sT  % %d.?.?).D & &' i-/"NN, %&rctjd|jr:tj|j }t j|_y|j |j|jj}|j }t j|_|jD] } |j|||j "y#t$rtjddYwxYw#tj $r3}tj#dt%j&|Yd}~d}~wt$rtj)dYwxYw)z(Flush events from recorder to exporters.zFlushing eventsNz"Scheduler before_flush hook failedT)exc_infoz'Unable to export profile: %s. Ignoring.zpUnexpected error while exporting events. Please report this bug to https://github.com/DataDog/dd-trace-py/issues)rrrruploadrrr before_flush Exceptionerrorrecorderreset exportersexportr ExportErrorwarningrformat_exception exception)rstarteventsexpes rflushzScheduler.flush+s. #$  % % KKM%%E & 0D      ( O!!#$$&!!"NN,>> C  65$*;*;<   O > N O'' g EzGbGbcdGeff  ^ s0)C(D( D  D E3!)E!E32E3c$tj} |jtd|jtj|z z |_y#td|jtj|z z |_wxYw)Nr)r monotonicr3maxrr)r start_times rrzScheduler.periodicJsp%%'  b JJL4#<#<@P@P@RU_@_#`aDMC4#<#<@P@P@RU_@_#`aDMs A5B)__name__ __module__ __qualname____doc__attribr'r)r$floatrupload_interval _intervalrrboolr* libdd_enabledrrrr3r __classcell__r s@rr r s+twwyH I4774E2LUF,B,BCI"477.477t>L#DGGv}}7R7RS2'>brr czeZdZdZdZdZejeeZ ejddZ fdZ xZ S) ServerlessSchedulerubServerless scheduler that works on, e.g., AWS Lambda. The idea with this scheduler is to not sleep 60s, but to sleep 1s and flush out profiles after 60 sleeping period. As the service can be frozen a few seconds after flushing out a profile, we want to make sure the next flush is not > 60s later, but after at least 60 periods of 1s. g?gN@)r r Fr)rr cj|j|jk\rgtj|jz |j |jzk\r, t t|#|j |_ d|_y|xjdz c_y#|j |_ d|_wxYw)Nr) _profiled_intervalsFLUSH_AFTER_INTERVALSrrrFORCED_INTERVALrrFrrrs rrzServerlessScheduler.periodiccs  # #t'A'A Av~~GWZ^ZkZkGk  4#=#= =G  -)49;!% 4 4 +,(  $ $ ) $!% 4 4 +,(s BB2) r8r9r:r;rKrJr<r=r>r@rIrrCrDs@rrFrFRsDO erUsy #%3(&-g!=b((=b=b@*)**r