Ki!:UddlZddlZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z m Z mZmZmZmZmZmZmZddlZddlZddlZddlmZmZddlmZddlmZdd lm Z m!Z"dd l#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*m+Z+m,Z,e rdd l-m.Z.m/Z/ej`e1Z2ejfe4d<Gdde5Z6edee fZ7e8e9e9fZ:GddeZ;dede fdejxfdZ!GddejzZ>GddZ?dejxde@fdZAy)N)contextmanager)datetime timedeltatimezone) TYPE_CHECKINGAnyAsyncGenerator AwaitableCallable GeneratorMappingProtocolcast) propagatetrace)suppress_instrumentation)Self)_signature_cache get_signature)ExecutionProgress ProgressEvent StateEvent)Logged) CACHE_SIZEmessage_gettermessage_setter)DocketRedisMessageIDloggerceZdZdZy)ExecutionCancelledz r(r+functionr.cft|}tjttddi|S)Ncache signature)_uncalled_for_get_signaturersetlenr)r7r:s r)rr?s++H5INN3'(7K*@A r(c2eZdZdZdZ dZ dZ dZ dZ dZ y) ExecutionStatez$Lifecycle states for task execution. scheduledqueuedrunning completedfailed cancelledN) r#r$r%r& SCHEDULEDQUEUEDRUNNING COMPLETEDFAILED CANCELLEDr'r(r)r?r?Es5.IL FSG7I/ F I:r(r?cleZdZdZ d>dddedeedfdeeefd ed e d e d e jjdzd ededzde ddfdZed?dZedefdZedeedffdZedeeeffdZedefdZedefdZede jjdzfdZedefdZede fdZededfdZdefdZe d@ddded ededzde f d Z!de"eeffd!Z#de"eee zffd"Z$d#edefd$Z%defd%Z&de'e(jRfd&Z* d@d'ed(d)ddfd*Z+d+edefd,Z,ddd-d.e-d/edzd0edzddfd1Z.dAd0edzddfd2Z/ dBd/edzd0edzddfd3Z0dCd4Z1ddd5d6e2dzd7e dzdefd8Z3dCd9Z4defd:Z5d;eddfd<Z6de7e8e9zdffd=Z:y)D ExecutionzRepresents a task execution with state management and progress tracking. Combines task invocation metadata (function, args, when, etc.) with Redis-backed lifecycle state tracking and user-reported progress. Ndocketrr7r-.kwargskeywhenattempt trace_context redelivered function_name generationr.c ~||_||_| xs |j|_||_||_||_||_||_||_ | |_ | |_ tj|_d|_d|_d|_d|_d|_t)|||_|j-d||_y)Nzruns:)_docket _functionr#_function_name_args_kwargs_keyrQrR_trace_context _redelivered _generationr?rFstateworker started_at completed_aterror result_keyrprogressrP _redis_key) r1rNr7r-rOrPrQrRrSrTrUrVs r)__init__zExecution.__init__bs !+@x/@/@     +'%&4%=%= "& +/-1!% &*,=VS+I !**uSE]3r(c|jS)zParent docket instance.)rXr1s r)rNzExecution.docket||r(c|jS)zTask function to execute.)rYrks r)r7zExecution.functions~~r(c|jS)z"Positional arguments for the task.)r[rks r)r-zExecution.argsszzr(c|jS)zKeyword arguments for the task.)r\rks r)rOzExecution.kwargsrlr(c|jS)zUnique task identifier.)r]rks r)rPz Execution.keysyyr(c|jS)z_Name of the task function (from message, may differ from function.__name__ for fallback tasks).)rZrks r)rUzExecution.function_name"""r(c|jS)zOpenTelemetry trace context.)r^rks r)rSzExecution.trace_contextrrr(c|jS)z%Whether this message was redelivered.)r_rks r)rTzExecution.redelivereds   r(c|jS)z9Scheduling generation counter for supersession detection.)r`rks r)rVzExecution.generationsr()NNNc#K|jjst5ddddydy#1swYyxYww)zASuppress OTel auto-instrumentation for internal Redis operations.N)rXenable_internal_instrumentationrrks r)_maybe_suppress_instrumentationz)Execution._maybe_suppress_instrumentations<||;;)+      s!A6A?Ac |jj|jjj|jjt j |jt j |jt|jjt|jjdS)N)keywhenfunctionargskwargsattempt generation) rPencoderQ isoformatrU cloudpickledumpsr-rOr4rRrVrks r) as_messagezExecution.as_messagesHHOO%YY((*113++224 &&tyy1"((5DLL)002t/668  r(message fallback_taskcHK|dj}|jj|x}s|td|d|}|||t j |dt j |d|djt j|djt|djtj|t ||t|jd d  }|jd{|S7w) Nr|zTask function z* is not registered with the current docketr}r~rzr{r)getterr0) rNr7r-rOrPrQrRrSrTrUrV) decodetasksget ValueErrorrloadsr fromisoformatintrextractrsync)clsrNrrTrrUr7instances r) from_messagezExecution.from_messages ,335 "LL,,];;;$ $]$55_`%H""77#34$$WY%78&&(''(8(?(?(AB +2245#++GNK#'7;;}d;<  mmo sDD"D D"cd|jiS)N docket.task)rUrks r)general_labelszExecution.general_labelsst1122r(c||j|j|jj|jdS)N)rz docket.keyz docket.whenzdocket.attempt)rUrPrQrrRrks r)specific_labelszExecution.specific_labelss3--((99..0"ll   r( parameterct|j}|j|ji|j}|j |Sr0)rr7bindr-rO arguments)r1rr: bound_argss r) get_argumentzExecution.get_arguments>!$--0 #Y^^TYY>$++> ##I..r(cg}|j}t|j}tj|}t |j j}t|jdt|D]O\}}||}|j|x} r!|j| j|?|jdQ|jjD]R\}}|j|x} r&|j|d| j|?|j|dT|ddj!|d|j"dS)N...=z=...(, z){})rUrr7rannotated_parametersr3 parametersr, enumerater-r=rappendformatrOitemsjoinrP) r1rrUr:logged_parametersparameter_namesiargumentparameter_nameloggeds r) call_reprzExecution.call_reprsT! ** !$--0 "77 By3388:;$TYY/E_1E%FG (KAx,Q/N*..~>>v>  x!89  '  ()- (9(9(; : $NH*..~>>v>  N#31V]]85L4M!NO  N#34!89  :  $))I"6!7s488*BGGr(ctj|j}|j}|jrtj |gSgSr0)rget_current_spanrSget_span_contextis_validLink)r1initiating_spaninitiating_contexts r)incoming_span_linkszExecution.incoming_span_linkssH001C1CD,==?3E3N3N -./VTVVr(replacereschedule_messagezRedisMessageID | Nonec K|j}tj|t|j}|j }|j j|}|tjtjk}|j j4d{}|j|dd4d{tt|j!d} | |j j"||j j%||j j&|j j)||j*g|t-|j/|rdnd|rdnd|xsd |j j0g|j3D cgc]\} } | | fD]} | c} } }  d{dddd{dddd{|rXt4j6|_|j;t4j6j<|j?d d{y|rXt4j@|_|j;t4j@j<|j?d d{yt4j6|_|j;t4j6j<|j?d d{y7V7:cc} } } w7>71#1d{7swYBxYw7:#1d{7swYKxYw777Kw) a\Schedule this task atomically in Redis. This performs an atomic operation that: - Adds the task to the stream (immediate) or queue (future) - Writes the execution state record - Tracks metadata for later cancellation Usage patterns: - Normal add: schedule(replace=False) - Replace existing: schedule(replace=True) - Reschedule from stream: schedule(reschedule_message=message_id) This atomically acknowledges and deletes the stream message, then reschedules the task to the queue. Prevents both task loss and duplicate execution when rescheduling tasks (e.g., due to concurrency limits). Args: replace: If True, replaces any existing task with the same key. If False, raises an error if the task already exists. reschedule_message: If provided, atomically acknowledges and deletes this stream message ID before rescheduling the task to the queue. Used when a task needs to be rescheduled from an active stream message. )setterNz:lock timeouta local stream_key = KEYS[1] -- TODO: Remove in next breaking release (v0.14.0) - legacy key locations local known_key = KEYS[2] local parked_key = KEYS[3] local queue_key = KEYS[4] local stream_id_key = KEYS[5] local runs_key = KEYS[6] local task_key = ARGV[1] local when_timestamp = ARGV[2] local is_immediate = ARGV[3] == '1' local replace = ARGV[4] == '1' local reschedule_message_id = ARGV[5] local worker_group_name = ARGV[6] -- Extract message fields from ARGV[7] onwards local message = {} local function_name = nil local args_data = nil local kwargs_data = nil local generation_index = nil for i = 7, #ARGV, 2 do local field_name = ARGV[i] local field_value = ARGV[i + 1] message[#message + 1] = field_name message[#message + 1] = field_value -- Extract task data fields for runs hash if field_name == 'function' then function_name = field_value elseif field_name == 'args' then args_data = field_value elseif field_name == 'kwargs' then kwargs_data = field_value elseif field_name == 'generation' then generation_index = #message end end -- Handle rescheduling from stream: atomically ACK message and reschedule to queue -- This prevents both task loss (ACK before reschedule) and duplicate execution -- (reschedule before ACK with slow reschedule causing redelivery) if reschedule_message_id ~= '' then -- Acknowledge and delete the message from the stream redis.call('XACK', stream_key, worker_group_name, reschedule_message_id) redis.call('XDEL', stream_key, reschedule_message_id) -- Increment generation counter local new_gen = redis.call('HINCRBY', runs_key, 'generation', 1) if generation_index then message[generation_index] = tostring(new_gen) end -- Park task data for future execution redis.call('HSET', parked_key, unpack(message)) -- Add to sorted set queue redis.call('ZADD', queue_key, when_timestamp, task_key) -- Update state in runs hash (clear stream_id since task is no longer in stream) redis.call('HSET', runs_key, 'state', 'scheduled', 'when', when_timestamp, 'function', function_name, 'args', args_data, 'kwargs', kwargs_data ) redis.call('HDEL', runs_key, 'stream_id') return 'OK' end -- Handle replacement: cancel existing task if needed if replace then -- Get stream ID from runs hash (check new location first) local existing_message_id = redis.call('HGET', runs_key, 'stream_id') -- TODO: Remove in next breaking release (v0.14.0) - check legacy location if not existing_message_id then existing_message_id = redis.call('GET', stream_id_key) end if existing_message_id then redis.call('XDEL', stream_key, existing_message_id) end redis.call('ZREM', queue_key, task_key) redis.call('DEL', parked_key) -- TODO: Remove in next breaking release (v0.14.0) - clean up legacy keys redis.call('DEL', known_key, stream_id_key) -- Note: runs_key is updated below, not deleted else -- Check if task already exists (check new location first, then legacy) local known_exists = redis.call('HEXISTS', runs_key, 'known') == 1 if not known_exists then -- Check if task is currently running (known field deleted at claim time) local state = redis.call('HGET', runs_key, 'state') if state == 'running' then return 'EXISTS' end -- TODO: Remove in next breaking release (v0.14.0) - check legacy location known_exists = redis.call('EXISTS', known_key) == 1 end if known_exists then return 'EXISTS' end end -- Increment generation counter local new_gen = redis.call('HINCRBY', runs_key, 'generation', 1) if generation_index then message[generation_index] = tostring(new_gen) end if is_immediate then -- Add to stream for immediate execution local message_id = redis.call('XADD', stream_key, '*', unpack(message)) -- Store state and metadata in runs hash redis.call('HSET', runs_key, 'state', 'queued', 'when', when_timestamp, 'known', when_timestamp, 'stream_id', message_id, 'function', function_name, 'args', args_data, 'kwargs', kwargs_data ) else -- Park task data for future execution redis.call('HSET', parked_key, unpack(message)) -- Add to sorted set queue redis.call('ZADD', queue_key, when_timestamp, task_key) -- Store state and metadata in runs hash redis.call('HSET', runs_key, 'state', 'scheduled', 'when', when_timestamp, 'known', when_timestamp, 'function', function_name, 'args', args_data, 'kwargs', kwargs_data ) end return 'OK' 10r(r,r-)rarQ)!rrinjectrrPrQrNknown_task_keyrnowrutcredislockrr+register_script stream_keyparked_task_key queue_key stream_id_keyrhr4 timestampworker_group_namerr?rFra_publish_statevaluerrG) r1rrrrPrQr is_immediaterschedule_scriptfieldritems r)schedulezExecution.schedules2'+oo&78hhyy33C8x||HLL99 ;;$$&z z %zz^$4E":BzGx x "&"))W [^#@& ..& 33C8 -- 11#6 DNN,-+&C*1c 55 18  ,u).!%!  Ex x z z z '11DJ%%(2288$..BRS  '..DJ%%(//55t~~?OP  (11DJ%%(2288$..BRS  Uz x d!Ex x x x z z z z @     sB#M%K;&M)L'K>L'CL'L<L L L L'L L' M*L$+AML=AML?AM5M6M>L'L L'L! LL! L'$M'L:-L0 .L:5 M?MMrbc Ktjtj}|j }|j 5|j j4d{}|jd}||j|jj|j j|j|j j|jg||t|jgd{}dddd{ddddk(ryt j"|_||_||_d|j_d|j_|j/t j"j0||dd{y 7?77#1d{7swYxYw#1swYxYw7-w) aAtomically check supersession and claim task in a single round-trip. This consolidates worker operations when claiming a task into a single atomic Lua script that: - Checks if the task has been superseded by a newer generation - Sets state to RUNNING with worker name and timestamp - Initializes progress tracking (current=0, total=100) - Deletes known/stream_id fields to allow task rescheduling - Cleans up legacy keys for backwards compatibility Args: worker: Name of the worker claiming the task Returns: True if the task was claimed, False if it was superseded. Na local runs_key = KEYS[1] local progress_key = KEYS[2] -- TODO: Remove in next breaking release (v0.14.0) - legacy key locations local known_key = KEYS[3] local stream_id_key = KEYS[4] local worker = ARGV[1] local started_at = ARGV[2] local generation = tonumber(ARGV[3]) -- Check supersession: generation > 0 means tracking is active if generation > 0 then local current = redis.call('HGET', runs_key, 'generation') if not current then -- Runs hash was cleaned up (execution_ttl=0 after -- a newer generation completed). This message is stale. return 'SUPERSEDED' end if tonumber(current) > generation then return 'SUPERSEDED' end end -- Update execution state to running redis.call('HSET', runs_key, 'state', 'running', 'worker', worker, 'started_at', started_at ) -- Initialize progress tracking redis.call('HSET', progress_key, 'current', '0', 'total', '100' ) -- Delete known/stream_id fields to allow task rescheduling redis.call('HDEL', runs_key, 'known', 'stream_id') -- TODO: Remove in next breaking release (v0.14.0) - legacy key cleanup redis.call('DEL', known_key, stream_id_key) return 'OK' rs SUPERSEDEDFrd)rarbrcT)rrrrrrxrNrrrhrgrrPrr4r`r?rHrarbrccurrenttotalrr)r1rbrcstarted_at_isor claim_scriptresults r)claimzExecution.claim s"\\(,,/ #--/  1 1 3< {{((*; ; e$44,0  d , 00 22488< 11$((;  !.#d6F6F2GH g; ; < | ] "$++  $ ! ! !!'//55 ,    a; fg; ; ; ; < < R sAGG%F$&G)BF+F'F+ GF)GBGG G$G'F+)G+F= 1F42F= 9GG Grerfrarerfc Ktjtjj }g}|r|j d|g||j d|g|j jr-t|j jjnd}|j5|j j4d{}|jd}||jgt|j|j |t|g|d{dddd{ddd||_|||_|j&j)d{|j |d} |r|| d<|j+| d{y777r#1d{7swYxYw#1swYxYw7[7.w)aMark task as having reached a terminal state. Args: state: The terminal state (COMPLETED, FAILED, or CANCELLED) error: Optional error message (for FAILED state) result_key: Optional key where the result/exception is stored Uses a Lua script to atomically check supersession and write the terminal state in a single round-trip. If the runs hash has been claimed by a successor (e.g. a Perpetual on_complete already called docket.replace()), the hash is left untouched. Progress data and the pub/sub completion event are always handled regardless of supersession. reNrfra. local runs_key = KEYS[1] local generation = tonumber(ARGV[1]) local state = ARGV[2] local completed_at = ARGV[3] local ttl_seconds = tonumber(ARGV[4]) -- Check supersession (generation 0 = pre-tracking, always write) if generation > 0 then local current = redis.call('HGET', runs_key, 'generation') if current and tonumber(current) > generation then return 'SUPERSEDED' end end -- Build HSET args: state + completed_at + any extras local hset_args = {'state', state, 'completed_at', completed_at} for i = 5, #ARGV, 2 do hset_args[#hset_args + 1] = ARGV[i] hset_args[#hset_args + 1] = ARGV[i + 1] end redis.call('HSET', runs_key, unpack(hset_args)) if ttl_seconds > 0 then redis.call('EXPIRE', runs_key, ttl_seconds) else redis.call('DEL', runs_key) end return 'OK' r)rard)rrrrrextendrN execution_ttlr total_secondsrxrrrhr4r`rrarfrgdeleter) r1rarerfrd extra_fields ttl_secondsrterminal_script state_datas r)_mark_as_terminalzExecution._mark_as_terminalrs, ||HLL1;;= #%    % 0 1  !   z : ;{{((  ))779 :   1 1 30 {{((*/ / e"'"7"7 ##J&//*D,,- $K(  &    M/ / 0 d  !(DOmm""$$$[[(&  "'Jw !!*---{/ L M/ / / / 0 0 l % .sB3G5GF-GAF3.F//F33 G>F1?G5G8G9.G'G(G-G/F31G3G 9F<:G GG GGcbK|jtj|d{y7w)zMark task as completed successfully. Args: result_key: Optional key where the task result is stored )rfN)rr?rI)r1rfs r)mark_as_completedzExecution.mark_as_completeds' $$^%=%=*$UUUs %/-/cdK|jtj||d{y7w)zMark task as failed. Args: error: Optional error message describing the failure result_key: Optional key where the exception is stored rN)rr?rJ)r1rerfs r)mark_as_failedzExecution.mark_as_faileds2$$  ! !:%   s &0.0c^K|jtjd{y7w)zMark task as cancelled.N)rr?rKrks r)mark_as_cancelledzExecution.mark_as_cancelleds $$^%=%=>>>s #-+-)rdeadlinerrc  K| | td|&tjtj|z}t j t jt jf j vrd}|R|tjtjz j}|dkrtdjd fd}tj||d{jt jk(rtdjd jt jk(rj rlj"j$j'j d{}|r3d |vr/t)j*|d }t-j.|}|j0xsd }t3|j rjj"j$j'j d{}|1d |vr-t)j*|d } t-j.| Sy7b#tj$rtdjdwxYw77mw) a'Retrieve the result of this task execution. If the execution is not yet complete, this method will wait using pub/sub for state updates until completion. Args: timeout: Optional duration to wait before giving up. If None and deadline is None, waits indefinitely. deadline: Optional absolute datetime when to stop waiting. If None and timeout is None, waits indefinitely. Returns: The result of the task execution, or None if the task returned None. Raises: ValueError: If both timeout and deadline are provided Exception: If the task failed, raises the stored exception TimeoutError: If timeout/deadline is reached before execution completes Nz(Cannot specify both timeout and deadlinerzTimeout waiting for execution z to completecKj23d{}|ddk(st|d}|vs%jd{y7:76yw)Ntypera) subscriber?r)eventrar1terminal_statess r)wait_for_completionz1Execution.get_result..wait_for_completion&sb'+~~'7&&e =G3$25>$BE$7&*iik 1 1 % & !2 (8sAAAAA AAA A AAAArz Execution z was cancelleddatazTask execution failed)rrrrrr?rIrJrKrar TimeoutErrorrPasynciowait_forr"rfrNresult_storagerbase64 b64decoderrre Exception) r1rrtimeout_secondsr result_datapickled_exception exception error_msgpickled_resultrs ` @r) get_resultzExecution.get_resultsJ4  8#7GH H  ||HLL1G;H  $ $  ! !  $ $  ::_ ,"O#x||HLL99-/ #a'&8 ,O &&&':'%JK K ::.. .$(KK$>$>$B$B4??$SS 6[#8(.(8(8V9L(M% + 1 12C DI#O =&=II& & ?? $ : : > >t OOK&6[+@!'!1!1+f2E!F"((88CW'' "4TXXJlK TPsPC J%I5I6I:BJ J  BJJ 8JI-JJ JcK|j5|jj4d{}|j|jd{}|r|j d}|r0t |tr|j}t||_ d|vr|djnd|_ d|vr&tj|djnd|_d|vr&tj|djnd|_d|vr|djnd|_d|vr|djnd|_n8tj$|_ d|_ d|_d|_d|_d|_dddd{ddd|j&j)d{y77~75#1d{7swYExYw#1swYIxYw7.w)zSynchronize instance attributes with current execution data from Redis. Updates self.state, execution metadata, and progress data from Redis. Sets attributes to None if no data exists. Nsstatesworkers started_ats completed_atserrors result_key)rxrNrhgetallrhr isinstancer6rr?rarbrrrcrdrerfrFrgr)r1rr state_values r)rzExecution.syncSs  1 1 3$ +{{((*# +# +e"]]4??;;"&((8"4K"%k59*5*<*<*>K%3K%@ 5>4EY..04K )D0!..tM/B/I/I/KL!O+d2!..tO/D/K/K/MN!% =ExYw#1swYBxYww)a9Check whether a newer schedule has superseded this execution. Compares this execution's generation against the current generation stored in the runs hash. If the stored generation is strictly greater, this execution has been superseded by a newer schedule() call. Generation 0 means the message predates generation tracking (e.g. it was moved from queue to stream by an older worker's scheduler that doesn't pass through the generation field). These are never considered superseded since we can't tell. rFNrV)r`rxrNrhgetrhr)r1rr current_gens r) is_supersededzExecution.is_supersededs   q   1 1 3 J{{((* J Je % 4??L II J J J'.&9c'lq T---- JI J J J J J Jsv!CB<B!B< B'&B#'B'+ B<6B%7B<;&C!B<#B'%B<'B9 -B0.B9 5B<<CCrcK|jjd|j}d|jd|}|jj|tj|d{y7w)znPublish state change to Redis pub/sub channel. Args: data: State data to publish state:ra)rrPN)rNrP_publishjsonr)r1rchannelpayloads r)rzExecution._publish_statese ++//F488*"5688   kk""7DJJw,?@@@sA,A6.A4/A6c K|jd{d|j|j|jj |j |j r|j j nd|jr|jj nd|jd}|d|j|jj|jj|jj|jjr$|jjj ndd}||jjd|j}|jjd|j}|jj4d{}|j!||d{|j#23d{}|dd k(st%j&|d }|ddk(rt)|d|d<|I77z7b7K6dddd{7y#1d{7swYyxYww) aSubscribe to both state and progress updates for this task. Emits the current state as the first event, then subscribes to real-time state and progress updates via Redis pub/sub. Yields: Dict containing state or progress update events with a 'type' field: - For state events: type="state", state, worker, timestamps, error - For progress events: type="progress", current, total, message, updated_at Nra)rrPrarQrbrcrdrerg)rrPrrr updated_atrz progress:rrr)rrPrarQrrbrcrdrergrrrrrN_pubsubrlistenrrr?)r1 initial_stateprogress_event state_channelprogress_channelpubsubr message_datas r)rzExecution.subscribesiik88ZZII'')kk9=$//335d151B1B!!++-ZZ % 88}},,]]((}},,}}''--22<<> )  & (;< ;;??Ytxxj+AB;;&&( ' 'F""=2BC C C!' ' 'g6?i/#'::gfo#>L#F+w60>|G?T0U W-&&S D ' C ' ' ' ' ' 'sIH+FI3H.4I7I H0I"H4&H2'H4* I47I+I.I0I2H44I5 IIII I II)NFNr)r.r)FNr0)NN)r.N);r#r$r%r& TaskFunctiontuplerdictr4rr opentelemetrycontextContextboolripropertyrNr7r-rOrPrUrSrTrVrr rxMessager classmethodrrr rrrrr3rrrrrr?rrrrrr rrrr rrrr'r(r)rMrM[s?C!$()4)4)4CHo )4 S#X )4  )4)4)4%,,44t;)4)4Tz)4)4 )4X,eCHoS#XS#s## #}44<3S 13 cCi!8 /c/c/ H3H.WT%**%5W TXmm9Pm m^e#e$eV!!% c.c.Tz c. $J c.  c.JV#*VVBF  4Z  47$J    ?%)$( aT!aT/ a aF-#^.T.( A A$ A5' ]0JD0P!Q5'r(rMr:cBg}d}|jjD]}t|jtj r|dz }-|j }|j|jurN|j}t|dr|jd}t|dt|}|j d|}|j|jur|d|j}|j||dkDr|jddj|S) Nrr __origin__r#z: z = rr)rvaluesrdefault uncalled_for Dependencyname annotationemptyhasattr__args__getattrr4rr)r:r dependenciesrparameter_definitionr5 type_names r)compact_signaturer=sJL))0020 i'')@)@ A A L (~~   y 6"--Jz<0'003  JJHI&/nn%5R {#C   IOO 3&:%;3y?P?P>S#T ./#0&a% 99Z  r()Brrenuminspectrlogging contextlibrrrrtypingrrr r r r r rrropentelemetry.contextr'r2rr _telemetryrtyping_extensionsruncalled_for.introspectionrrr;_execution_progressrrr annotationsrinstrumentationrrrrNrr getLoggerr#r Logger__annotations__rr"r$r&r6r,r+ SignatureEnumr?rMr4r=r'r(r)rOs  %22   *0"  NMGG.***844  Ys^+, ue| X HS#X.73D3D ;TYY;,~ '~ 'B!!2!2!s!r(