oq'j ^ d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl m
Z
m Z m Z m
Z
ddlmZ ddlmZ ej e ZdZ ej d ej Z ej d
ej Z ej d ej ZddZ G d d Z ddZ G d d Z dS )uT MemoryManager — orchestrates memory providers for the agent.
Single integration point in run_agent.py. Replaces scattered per-backend
code with one manager that delegates to registered providers.
Only ONE external plugin provider is allowed at a time — attempting to
register a second external provider is rejected with a warning. This
prevents tool schema bloat and conflicting memory backends.
Usage in run_agent.py:
self._memory_manager = MemoryManager()
# Only ONE of these:
self._memory_manager.add_provider(plugin_provider)
# System prompt
prompt_parts.append(self._memory_manager.build_system_prompt())
# Pre-turn
context = self._memory_manager.prefetch_all(user_message)
# Post-turn
self._memory_manager.sync_all(user_msg, assistant_response)
self._memory_manager.queue_prefetch_all(user_msg)
) annotationsN)ThreadPoolExecutor)AnyDictListOptional)MemoryProvider)
tool_errorg @zz5<\s*memory-context\s*>[\s\S]*?z\[System note:\s*The following is recalled memory context,\s*NOT new user input\.\s*Treat as (?:informational background data|authoritative reference data[^\]]*)\.\]\s*textstrreturnc t d| } t d| } t d| } | S )zQStrip fence tags, injected context blocks, and system notes from provider output. )_INTERNAL_CONTEXT_REsub_INTERNAL_NOTE_RE
_FENCE_TAG_RE)r s 9/home/ubuntu/.hermes/hermes-agent/agent/memory_manager.pysanitize_contextr > sF # #B - -D T * *D R & &D K c e Zd ZdZdZdZddZddZd d
Zd d Z e
d d Z d dZ d dZ
d dZd dZd!dZd"dZdS )#StreamingContextScrubbera Stateful scrubber for streaming text that may contain split memory-context spans.
The one-shot ``sanitize_context`` regex cannot survive chunk boundaries:
a ```` opened in one delta and closed in a later delta
leaks its payload to the UI because the non-greedy block regex needs
both tags in one string. This scrubber runs a small state machine
across deltas, holding back partial-tag tails and discarding
everything inside a span (including the system-note line).
Usage::
scrubber = StreamingContextScrubber()
for delta in stream:
visible = scrubber.feed(delta)
if visible:
emit(visible)
trailing = scrubber.flush() # at end of stream
if trailing:
emit(trailing)
The scrubber is re-entrant per agent instance. Callers building new
top-level responses (new turn) should create a fresh scrubber or call
``reset()``.
zzr
Nonec 0 d| _ d| _ d| _ d S NFr T_in_span_buf_at_block_boundaryselfs r __init__z!StreamingContextScrubber.__init__c s #
(, r c 0 d| _ d| _ d| _ d S r r r s r resetz StreamingContextScrubber.reseth s
"& r r r c |sdS | j |z }d| _ g }|r| j r| | j }|dk rD| || j }|r || d nd| _ d | S ||t | j z d }d| _ n| | }|dk r| | p| || j
}|r0| ||d| || d | _ n| || d | S |dk r | ||d| ||t | j
z d }d| _ |d | S )a Return the visible portion of ``text`` after scrubbing.
Any trailing fragment that could be the start of an open/close tag
is held back in the internal buffer and surfaced on the next
``feed()`` call or discarded/emitted by ``flush()``.
r NFr T) r r lowerfind
_CLOSE_TAG_max_partial_suffixjoinlen_find_boundary_open_tag_max_pending_open_suffix _OPEN_TAG_append_visible)r! r bufoutidxhelds r feedz StreamingContextScrubber.feedm s 2i$ %}
%iikk&&t77"99 33C IID/3 ;TEFF DI 773<<'#DO 4 44556 %
22377"99 55c:: I 33C HH 7 ,,S#fuf+>>>$'K ,,S#666 773<<'77((c$3$i888#DN 3 33445 $
; %> wws||r c P | j rd| _ d| _ dS | j }d| _ |S )aQ Emit any held-back buffer at end-of-stream.
If we're still inside an unterminated span the remaining content is
discarded (safer: leaking partial memory context is worse than a
truncated answer). Otherwise the held-back partial-tag tail is
emitted verbatim (it turned out not to be a real tag).
r F)r r )r! tails r flushz StreamingContextScrubber.flush s4 = DI !DM2y r r1 tagintc | }| }t t | t | dz
}t |dd D ]$}| || d r|c S %dS )zReturn the length of the longest buf-suffix that is a tag-prefix.
Case-insensitive. Returns 0 if no suffix could start the tag.
r r& N)r' minr, range
startswith)r1 r9 tag_lower buf_lower max_checkis r r* z,StreamingContextScrubber._max_partial_suffix s IIKK IIKK II(:;; y!R(( A##IqbccN33
qr c | }d} | | j | }|dk rdS | || r| || r|S |dz }W)z>Cbyyr&&sC00
T5R5RSVX[5\5\
7L
#r c | | j sdS t | t | j z
}| || sdS t | j S )zBHold a complete boundary tag until the following char confirms it.r )r' endswithr/ r, rE )r! r1 r3 s r r. z1StreamingContextScrubber._max_pending_open_suffix sn yy{{##DN33 1#hhT^,,,&&sC00 14>"""r r3 boolc n |t | j z }|t | k rdS || dv S )NFz
)r, r/ )r! r1 r3 after_idxs r rF z1StreamingContextScrubber._has_block_opener_suffix s; #dn--- C 59~''r c |dk r| j S |d | }| d }|dk r | j o| dk S ||dz d dk S )Nr
r& r r< )r rfindstrip)r! r1 r3 preceding last_newlines r rE z+StreamingContextScrubber._is_block_boundary s !88* *I t,, 2 *Fy/@/@B/F F )**+1133r99r r2 list[str]c b |sd S | | | | d S N)append_update_block_boundary)r! r2 r s r r0 z(StreamingContextScrubber._append_visible s; F
4 ##D)))))r c | d }|dk r*||dz d dk | _ d S | j o| dk | _ d S )NrN r& r< r )rO rP r )r! r rR s r rW z/StreamingContextScrubber._update_block_boundary sq zz$'' 2 &*
[System note: The following is recalled memory context, NOT new user input. Treat as authoritative reference data — this is the agent's persistent memory and should inform all responses.]
z
)rP r loggerwarning)rb cleans r build_memory_context_blockrg sk k / / 1 1 r [ ) )E OPPP r c T e Zd ZdZdLdZdMdZedNd ZdOd
ZdPdZ dddQdZ
dddRdZ e dSd Z
ddddTd ZdLd ZdUd ZdVdWd#ZdXd%ZdYd'ZdZd)Zd[d,Zd\d0Zd]d1Zdd2d2d3d^d8Zd_d9Ze d`d: Z dVdad@ZddAdbdEZ dLdFZ dLdGZ e dcdJ Z dddKZ dS )e
MemoryManagerzOrchestrates the built-in provider plus at most one external provider.
The builtin provider is always first. Only one non-builtin (external)
provider is allowed. Failures in one provider never block the other.
r
r c n g | _ i | _ d| _ d | _ t j | _ d S )NF)
_providers_tool_to_provider
_has_external_sync_executor threadingLock_sync_executor_lockr s r r" zMemoryManager.__init__ s: 02<> #( =A#,>#3#3 r providerr c |j dk }|sP| j rBt d | j D d }t d|j | dS d| _ | j | ddlm} t | }|
D ]}| d d
}||v r"t d |j | >|r|| j vr || j |< T|| j v r2t d || j | j |j t
d
|j t |
dS )u Register a memory provider.
Built-in provider (name ``"builtin"``) is always accepted.
Only **one** external (non-builtin) provider is allowed — a second
attempt is rejected with a warning.
builtinc 3 : K | ]}|j d k
|j V dS )rt N)name.0ps r z-MemoryManager.add_provider.. s0 LL)8K8KQV8K8K8K8KLLr unknownu Rejected memory provider '%s' — external provider '%s' is already registered. Only one external memory provider is allowed at a time. Configure which one via memory.provider in config.yaml.NTr _HERMES_CORE_TOOLSrv r u Memory provider '%s' tool '%s' shadows a reserved core tool name; registration ignored. Core tools always win — rename the provider's tool to something unique.zJMemory tool name conflict: '%s' already registered by %s, ignoring from %sz*Memory provider '%s' registered (%d tools))rv rm nextrk rd re rV toolsetsr} setget_tool_schemasgetrl infor, )r! rr
is_builtinexistingr} _core_tool_namesschema tool_names r add_providerzMemoryManager.add_provider s ]i/
&!
LLT_LLLi & M8 !%D x((( 0///// 122 //11 F
62..I ,,,F M9
Yd.D D D4<&y11d 444' *95: M 8 M ))++ , ,
r List[MemoryProvider]c * t | j S )z"All registered providers in order.)listrk r s r providerszMemoryManager.providersR s DO$$$r rv r Optional[MemoryProvider]c 8 | j D ]}|j |k r|c S dS )z2Get a provider by name, or None if not registered.N)rk rv )r! rv ry s r get_providerzMemoryManager.get_providerW s1 Av~~ tr c 4 g }| j D ]z} | }|r)| r| | C# t $ r+}t
d|j | Y d}~sd}~ww xY wd | S )zCollect system prompt blocks from all providers.
Returns combined text, or empty string if no providers contribute.
Each non-empty block is labeled with the provider name.
z5Memory provider '%s' system_prompt_block() failed: %sN
) rk system_prompt_blockrP rV Exceptionrd re rv r+ )r! blocksrr blockes r build_system_promptz!MemoryManager.build_system_prompt` s H
4466 )U[[]] )MM%(((
K M1
{{6"""s ?A
B!A==Br
session_idqueryr c : g }| j D ]}} | || }|r)| r| | F# t $ r+}t
d|j | Y d}~vd}~ww xY wd | S )zCollect prefetch context from all providers.
Returns merged context text labeled by provider. Empty providers
are skipped. Failures in one provider don't block others.
r z4Memory provider '%s' prefetch failed (non-fatal): %sNr ) rk prefetchrP rV r rd debugrv r+ )r! r r partsrr resultr s r prefetch_allzMemoryManager.prefetch_allu s H
!**5Z*HH )fllnn )LL(((
J M1
{{5!!!s AA
B!B Bc v t | j sdS dfd }| | dS )a! Queue background prefetch on all providers for the next turn.
Provider work is dispatched to a background worker so a slow or
wedged provider can never block the caller. See ``sync_all`` for
the full rationale (agent stuck "running" minutes after a turn).
Nr
r c D ]R} | # t $ r+}t d| j | Y d }~Kd }~ww xY wd S )Nr z:Memory provider '%s' queue_prefetch failed (non-fatal): %s)queue_prefetchr rd r rv )rr r r r r s r _runz.MemoryManager.queue_prefetch_all.._run s %
++Ej+IIII LLT
q
s
A!AArY r rk _submit_background)r! r r r r s `` @r queue_prefetch_allz MemoryManager.queue_prefetch_all sg )) F
%%%%%r rJ c t j | j }n# t t f$ r Y dS w xY wt |j }t d |D rdS d|j v S )z4Return whether sync_turn accepts a messages keyword.Tc 3 J K | ] }|j t j j k V d S rU kindinspect Parameter VAR_KEYWORDrw s r rz z@MemoryManager._provider_sync_accepts_messages.. / GG1qv*66GGGGGGr messages) r signature sync_turn TypeError
ValueErrorr
parametersvaluesany)rr r paramss r _provider_sync_accepts_messagesz-MemoryManager._provider_sync_accepts_messages s )(*<==II:& 44 i*113344 GGGGG G G 4Y 111 11Nr r user_contentassistant_contentr Optional[List[Dict[str, Any]]]c t j sdS d fd } | dS )u Sync a completed turn to all providers.
Runs on a background worker thread, NOT inline on the
turn-completion path. A provider's ``sync_turn`` may make a
blocking network/daemon call (a misconfigured Hindsight daemon
was observed blocking ~298s before failing); doing that inline
held ``run_conversation`` open long after the user saw their
response, so every interface (CLI, TUI, gateway) kept the agent
marked "running" for minutes and any follow-up message triggered
an aggressive interrupt. Dispatching off-thread means a slow or
broken provider can never stall the turn — the sync simply
completes (or fails, logged) in the background.
Writes are serialized through a single worker so turn N lands
before turn N+1; provider implementations don't need their own
ordering guarantees.
Nr
r c D ]} / | r| n| M# t $ r+}t d| j | Y d }~}d }~ww xY wd S )Nr r z)Memory provider '%s' sync_turn failed: %s)r r r rd re rv )rr r r r r r! r r s r r z$MemoryManager.sync_all.._run s %
+0T0TU]0^0^+ ** ( -'1%- + !** ( -'1 +
! NNC
q
s A A
B!BBrY r )r! r r r r r r s ````` @r sync_allzMemoryManager.sync_all sy 2 )) F ,
%%%%%r c ~ | }|@ | n2# t $ r%}t d| Y d}~nd}~ww xY wdS | | dS # t
$ rC | Y dS # t $ r'}t d| Y d}~Y dS d}~ww xY ww xY w)u Run ``fn`` on the manager's background worker.
The executor is created lazily and shared across calls. If the
executor can't be created or has already been shut down, ``fn``
runs inline as a last-resort fallback — losing the async benefit
but never losing the write itself. ``fn`` must do its own
per-provider error handling; this wrapper only guards executor
plumbing.
Nz(Inline memory background task failed: %s)_get_sync_executorr rd r submit RuntimeError)r! fnexecutorr s r r z MemoryManager._submit_background s **,,
L
L
L
L GKKKKKKKK
L F L OOB L L L
L
L
L
L GKKKKKKKKKK
L LsD
#
AA
AA/ /
B<:
B
B8B3,B<3B88B< Optional[ThreadPoolExecutor]c ( | j | j S | j 5 | j V t dd | _ n># t $ r1}t d| Y d}~ddd dS d}~ww xY w| j cddd S # 1 swxY w Y dS )z4Lazily create the single-worker background executor.Nr< zmem-sync) max_workersthread_name_prefixz)Failed to create memory sync executor: %s)rn rq r r rd re )r! r s r r z MemoryManager._get_sync_executor s *& &
%
'
'"* *<$%+5+ + +D'' ! NN#NPQRRR 444
'
'
'
'
'
'
'
' &
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
'
's7 B6B
A1 A,B,A11 BB B timeoutOptional[float]c | j }|dS | d }n# t $ r Y dS w xY w | | dS # t $ r Y dS w xY w)a Block until queued sync/prefetch work has drained.
Single-worker executor means submitting a sentinel and waiting on
it guarantees every previously-submitted task has run. Returns
True if the barrier completed within ``timeout`` (or no executor
exists), False on timeout. Used at real session boundaries and by
tests that need to assert provider state deterministically.
NTc d S rU ra ra r r z-MemoryManager.flush_pending.. s $ r r F)rn r r r r )r! r r futs r
flush_pendingzMemoryManager.flush_pending s & 4 //,,//CC 44 JJwJ ' ' '4 55 s $
22A
A A List[Dict[str, Any]]c ddl m} t | }g }t }| j D ]} | D ]M}| dd }||v r |r.||vr*| | | | Nf# t $ r+}t
d|j | Y d}~d}~ww xY w|S )uC Collect tool schemas from all providers.
Reserved core tool names (``clarify``, ``delegate_task``, etc.) are
skipped — they are rejected from the routing table in
:meth:`add_provider`, so the manager must not advertise a schema it
will never route. Built-ins always win (#40466).
r r| rv r z2Memory provider '%s' get_tool_schemas() failed: %sN) r r} r rk r r rV addr rd re rv ) r! r} r schemasseenrr r rv r s r get_all_tool_schemasz"MemoryManager.get_all_tool_schemas* s 0///// 122uu
H
& 7 7 9 9 ' 'F!::fb11D /// 'D 0 0 v...
'
H M1
s A"B
C !CCr c N t | j S )z2Return set of all tool names across all providers.)r rl keysr s r get_all_tool_namesz MemoryManager.get_all_tool_namesG s 4)..00111r r c || j v S )z(Check if any provider handles this tool.)rl )r! r s r has_toolzMemoryManager.has_toolK s D 222r argsDict[str, Any]c | j | }|t d| d S |j ||fi |S # t $ rA}t
d|j || t d| d| cY d}~S d}~ww xY w)zRoute a tool call to the correct provider.
Returns JSON string result. Raises ValueError if no provider
handles the tool.
Nz!No memory provider handles tool ''z4Memory provider '%s' handle_tool_call(%s) failed: %sz
Memory tool 'z
' failed: )rl r r
handle_tool_callr rd errorrv )r! r r kwargsrr r s r r z MemoryManager.handle_tool_callO s )--i88 N) N N NOO O H,8,YGGGG G H H H LLF
y!
Fi F F1 F FGG G G G G G G Hs A
B
6B B B turn_numberr: messagec | j D ]J} |j ||fi | # t $ r+}t d|j | Y d}~Cd}~ww xY wdS )zxNotify all providers of a new turn.
kwargs may include: remaining_tokens, model, platform, tool_count.
z-Memory provider '%s' on_turn_start failed: %sN)rk
on_turn_startr rd r rv )r! r r r rr r s r r zMemoryManager.on_turn_starte s
H
&&{GFFvFFFF
C M1
s
A!A Ac | j D ]P} | | # t $ r+}t d|j | Y d}~Id}~ww xY wdS )z$Notify all providers of session end.z.Memory provider '%s' on_session_end failed: %sN)rk on_session_endr rd r rv )r! r rr r s r r z MemoryManager.on_session_ends s H
''1111
D M1
s !
A!AAF)parent_session_idr$ rewoundnew_session_idr r$ r c |sdS |rd|d< | j D ]L} |j |f||d| # t $ r+}t d|j | Y d}~Ed}~ww xY wdS )u Notify all providers that the agent's session_id has rotated.
Fires on ``/resume``, ``/branch``, ``/reset``, ``/new``, and
context compression — any path that reassigns
``AIAgent.session_id`` without tearing the provider down.
Providers keep running; they only need to refresh cached
per-session state so subsequent writes land in the correct
session's record. See ``MemoryProvider.on_session_switch`` for
the full contract.
``rewound=True`` signals that session_id is unchanged but the
transcript was truncated; providers caching per-turn document
state should invalidate.
NTr )r r$ z1Memory provider '%s' on_session_switch failed: %s)rk on_session_switchr rd r rv )r! r r r$ r r rr r s r r z MemoryManager.on_session_switch~ s 0 F % $F9 H
**"&7
G M1
s (
A !AA c 6 g }| j D ]{} | | }|r)| r| | D# t $ r+}t
d|j | Y d}~td}~ww xY wd | S )zNotify all providers before context compression.
Returns combined text from providers to include in the compression
summary prompt. Empty string if no provider contributes.
z/Memory provider '%s' on_pre_compress failed: %sNr ) rk on_pre_compressrP rV r rd r rv r+ )r! r r rr r r s r r z MemoryManager.on_pre_compress s H
!11(;; )fllnn )LL(((
E M1
{{5!!!s A A
B!A>>Bc F t j | j }n# t t f$ r Y dS w xY wt |j }t d |D rdS d|j v rdS d |D }t | dk rdS dS )z>Return how to pass metadata to a provider's memory-write hook.keywordc 3 J K | ] }|j t j j k V d S rU r rw s r rz zEMemoryManager._provider_memory_write_metadata_mode.. r r metadatac g | ]=}|j t j j t j j t j j hv ;|>S ra )r r r POSITIONAL_ONLYPOSITIONAL_OR_KEYWORD KEYWORD_ONLYrw s r
zFMemoryManager._provider_memory_write_metadata_mode.. sW
v!1!7!.
r
positionallegacy)
r r on_memory_writer r r r r r r, )rr r r accepteds r $_provider_memory_write_metadata_modez2MemoryManager._provider_memory_write_metadata_mode s )(*BCCII:& 99 i*113344 GGGGG G G 9 - - - 9
x==A <xr actiontargetcontentr Optional[Dict[str, Any]]c | j D ]}|j dk r | | }|dk r)| |||t |pi nE|dk r(| |||t |pi n| ||| # t
$ r+}t d|j | Y d}~d}~ww xY wdS )zNotify external providers when the built-in memory tool writes.
Skips the builtin provider itself (it's the source of the write).
rt r )r r z/Memory provider '%s' on_memory_write failed: %sN)rk rv r r dictr rd r )r! r r r r rr
metadata_moder s r r z MemoryManager.on_memory_write s1 H} ))
$ I I( S S
I-- ,, $x~2:N:N - #l22 ,,VVWd8>WYFZFZ[[[[ ,,VVWEEE
E M1
s B B!!
C+!CC)child_session_idtaskr r
c | j D ]L} |j ||fd|i| # t $ r+}t d|j | Y d}~Ed}~ww xY wdS )z/Notify all providers that a subagent completed.r
z-Memory provider '%s' on_delegation failed: %sN)rk
on_delegationr rd r rv )r! r r r
r rr r s r r
zMemoryManager.on_delegation s H
&&& 3CGM
C M1
s
A!A
Ac | t | j D ]O} | # t $ r+}t
d|j | Y d}~Hd}~ww xY wdS )a Shut down all providers (reverse order for clean teardown).
Drains the background sync/prefetch executor first (bounded by
``_SYNC_DRAIN_TIMEOUT_S``) so a turn's final sync has a chance to
land before providers are torn down. The worker threads are
daemon, so anything still wedged past the drain window dies with
the interpreter rather than blocking exit.
z(Memory provider '%s' shutdown failed: %sN)_drain_sync_executorreversedrk shutdownr rd re rv )r! rr r s r shutdown_allzMemoryManager.shutdown_all s
!!### 11 H
!!####
> M1
s A
A6 !A11A6c D j 5 j d _ ddd n # 1 swxY w Y dS dd n# t $ rN d n2# t $ r%}t
d| Y d}~nd}~ww xY wY dS t $ r&}t
d| Y d}~dS d}~ww xY wt j fddd }| |
t
dS ) a Shut down the background executor, waiting briefly for drain.
Bounded by ``_SYNC_DRAIN_TIMEOUT_S``: a wedged provider must never
hang process/session teardown. We stop accepting new work and
cancel anything still queued, then wait at most the drain timeout
for the currently-running task on a watcher thread. The worker is
daemon, so an over-running task dies with the interpreter.
NFT)waitcancel_futuresr z(Memory sync executor shutdown failed: %sc . S rU )_bounded_executor_wait)r r! s r r z4MemoryManager._drain_sync_executor..: s 466x@@ r zmem-sync-drain)r daemonrv r ) rq rn r r r rd r ro Threadstartr+ _SYNC_DRAIN_TIMEOUT_S)r! r drainerr s ` @r r z"MemoryManager._drain_sync_executor s
% ' '*H"&D ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' F
5 > > > >
L!!u!----
L
L
L GKKKKKKKK
L FF LLCQ G G G FFFFF
"@@@@@!
2 33333sS %))A
CA/.C/
B 9BCB C$ C-CCr r c | d d S # t $ r&}t d| Y d }~d S d }~ww xY w)NTr z*Memory sync executor drain wait failed: %s)r r rd r )r r s r r z$MemoryManager._bounded_executor_waitA so J 4 ( ( ( ( ( J J J LLEq I I I I I I I I I Js
A
AA
c d|vr ddl m} t | |d< | j D ]J} |j dd|i| # t
$ r+}t d|j | Y d}~Cd}~ww xY wdS )zInitialize all providers.
Automatically injects ``hermes_home`` into *kwargs* so that every
provider can resolve profile-scoped storage paths without importing
``get_hermes_home()`` themselves.
hermes_homer )get_hermes_homer z*Memory provider '%s' initialize failed: %sNra ) hermes_constantsr! r rk
initializer rd re rv )r! r r r! rr r s r initialize_allz MemoryManager.initialize_allH s & & 8 8 8 8 8 8$'(9(9$:$:F= ! H
##DDzDVDDDD
@ M1
s ?
A4 !A//A4rY )rr r r
r )r
r )rv r r
r r[ )r r r r r
r )r r r r r
r )rr r r
rJ )
r r r r r r r r r
r )r
r rU )r r r
rJ )r
r )r
r )r r r
rJ )r r r r r
r )r r: r r r
r )r r r
r )
r r r r r$ rJ r rJ r
r )r r r
r )rr r r
r )
r r r r r r r r r
r )r r r r r
r r
r )r r r
r )r r r
r )!r\ r] r^ r_ r" r propertyr r r r r r` r r r r r r r r r r r r r r r r
r r r r$ ra r r ri ri s
4
4
4
4 ?
?
?
?
B % % % X% # # # #* =? " " " " " "& CE & & & & & &2 2 2 2 \ 2 37
3& 3& 3& 3& 3& 3&nL L L L:' ' ' ' 2 :2 2 2 23 3 3 3H H H H, "$
. . . . . .`" " " "& \< .2 > /1 &%4 %4 %4 %4N J J J \J r ri rZ )rb r r
r ) r_
__future__r loggingrer ro concurrent.futuresr typingr r r r agent.memory_providerr tools.registryr
getLoggerr\ rd r compile
IGNORECASEr r r r r rg ri ra r r r0 s 2 # " " " " " 1 1 1 1 1 1 , , , , , , , , , , , , 0 0 0 0 0 0 % % % % % % 8 $ $
6
FF
!rz<M BJ pM bU bU bU bU bU bU bU bUJ "] ] ] ] ] ] ] ] ] ] r