鎒j6dZddlZddlZddlmZmZmZddlmZ e j j e j j e j j dZdedee jgedfde jfd Zd eejzdee jee jgedfde jfd ZdS) zHelper factories for common trigger patterns. These are thin wrappers that return Trigger callables with correct cancellation handling built in. N) AwaitableCallableSequence)triggers)interval_secondscallbackreturncdkrtddtjddffd }dd|_d d |_|S) u5Creates a trigger that runs callback on a fixed interval. The callback is invoked repeatedly with `interval_seconds` between each invocation. The first invocation happens after the first interval elapses (not immediately). Args: interval_seconds: Seconds between invocations. Must be positive. callback: Async function called each interval. Receives the TriggerContext — use ctx.send() inside the callback to push messages to the agent. Returns: A Trigger function. Raises: ValueError: If interval_seconds is not positive. rz'interval_seconds must be positive, got ctxr NcbK tjd{V|d{V,)N)asynciosleep)rr r s QC:\Projects\DSCons\.venv\Lib\site-packages\google\antigravity\triggers\helpers.py_triggerzevery.._triggerAsT M* + ++++++++ HSMMevery_szInterval trigger: runs every zs.) ValueErrortriggers_moduleTriggerContext__name____doc__)r r rs`` reveryr's* D2BDD  /8T 3/222(I5EIII( /rpathct|dtjddffd }dtjj|_dd|_|S)a/Creates a trigger that calls callback when files at path change. Uses watchfiles for efficient OS-level file watching. The watchfiles dependency is imported lazily so it's only required when this helper is actually used. Raw watchfiles events are converted to ``FileChange`` objects before being passed to the callback. Args: path: File or directory path to watch. callback: Async function called with (ctx, changes) on each change event. ``changes`` is a sequence of ``FileChange`` objects. Returns: A Trigger function. rr NcK ddl}n"#t$r}td|d}~wwxYw|23d{V}d|D}||d{V&6dS)NrzPwatchfiles is required for on_file_change triggers. Add it to your dependencies.c g|]P\}}tjtt |tjj|QS))kindr)r FileChange_WATCHFILES_CHANGE_MAPgetintFileChangeKindMODIFIED).0 change_type changed_paths r z4on_file_change.._trigger..nsk(k<  $)--k""O$B$K    r) watchfiles ImportErrorawatch)rr,e raw_changeschangesr watch_paths rrz on_file_change.._triggeres   )   (..z:: # # # # # # #k,7g HS' " """"""""";::s )$)A'on_file_change_zFile watcher trigger for .)strrrpathlibPathnamerr)rr rr2s ` @ron_file_changer9Ks}04yy*#/8#T#######(H Z(@(@(EGG(>>>>( /r)rrr6typingrrrgoogle.antigravity.triggersrrr&ADDEDr'DELETEDr#floatrTriggerrr5r7r"r9rrrAs) 0000000000CCCCCC%+%.%-!!674HI!!!!!H0  0  '/2L)MN$ 0  000000r