Fh>SrSSKJr SSKrSSKrSSKrSSKrSSKrSSK r SSK J r J r SSK J r SSKJr SSKJr SSKJrJrJrJr SS KJrJr S S KJr S S KJr S S KJr S SK J!r! \ "S5r"\"\"5\"S5:aSSK#J$r$ OSSK%J$r$ S r&"SS\'5r("SS\)5r*"SS\)5r+\ RX"S\(5 "SS\)5r-"SS\5r.g)z? Emit structured, discrete events when various actions happen. ) annotationsN)datetimetimezone)version)ValidationError)parse)DictInstanceSetdefault)ConfigLoggingConfigurable) SchemaTypeSchemaRegistry)Handlers)JUPYTER_EVENTS_CORE_VALIDATORzpython-json-loggerz3.1.0) JsonFormatterc\rSrSrSrSrg)SchemaNotRegistered%zrA warning to raise when an event is given to the logger but its schema has not be registered with the EventLogger N__name__ __module__ __qualname____firstlineno____doc____static_attributes__rhC:\Users\julio\OneDrive\Documentos\Trabajo\Ideas Frescas\venv\Lib\site-packages\jupyter_events/logger.pyrr%r!rc\rSrSrSrSrg) ModifierError+zJAn exception to raise when a modifier does not show the proper signature. rNrrr!r"r%r%+r#r!r%c\rSrSrSrSrg)CoreMetadataError1z:An exception raised when event core metadata is not valid.rNrrr!r"r(r(1sDr!r(oncec\rSrSrSrSrg) ListenerError:zJAn exception to raise when a listener does not show the proper signature. rNrrr!r"r,r,:r#r!r,c^\rSrSr%Sr\"SSSS9R SS9r\"\ SS 9r \ "0S S 9r \ "0S S 9r \ "0S S 9r\"5rS \S'S Sjr\"S5S!Sj5rS"U4SjjrS#S$U4SjjjrS%SjrS&SjrS&SjrSS.S'SjjrSS.S'SjjrSSS.S(SjjrSS.S)SjjrSS.S*SjjrSrU=r $)+ EventLogger@z An Event logger for emitting structured events. Event schemas must be registered with the EventLogger using the `register_schema` or `register_schema_file` methods. Every schema will be validated against Jupyter Event's metaschema. NTzA list of logging.Handler instances to send events to. When set to None (the default), all events are discarded. ) default_value allow_nonehelp)configzbThe SchemaRegistry for caching validated schemas and their jsonschema validators. )r3z0A mapping of schemas to their list of modifiers.z9A mapping of schemas to the listeners of modified events.z?A mapping of schemas to the listeners of unmodified/raw events.zset[asyncio.Task[t.Any]]_active_listenersc^# [R"URSS06IShvN $N7f)z#Gather all of the active listeners.return_exceptionsTN)asynciogatherr5selfs r"gather_listenersEventLogger.gather_listenersds%^^T%;%;TtTTTTs $-+-schemasc[5$Nrr:s r"_default_schemasEventLogger._default_schemashs r!cx>[TU]"U0UD6 [S-[[ U55-n[ R "U5UlSURlURR[ R5 UR(a%URHnURU5 M gg)zInitialize the logger..FN) super__init__rstridlogging getLogger_logger propagatesetLevelINFOhandlersregister_handler)r;argskwargslog_namehandler __class__s r"rFEventLogger.__init__ls $)&)c>C4M1((2 !&  gll+ ====%%g.) r!c>^URU5nURS/5mSU4SjjnXTS'[SU05n[TU]USSS9 g)zyLoad EventLogger traits from a Config object, patching the handlers trait in the Config object to avoid deepcopy errors. rOc>T$r@r)rOsr" get_handlers.EventLogger._load_config..get_handlerssOr!r/N) section_namestraits)returnzlist[logging.Handler])_find_my_configpopr rE _load_config) r;cfgr[r\my_cfgrYeventlogger_cfgrOrUs @r"r`EventLogger._load_config~sY%%c**0**Z*D *z!-!89 _DNr!c8URRU5nURnX0R;a[ 5URU'X0R ;a[ 5UR U'X0R ;a[ 5UR U'gg)zvRegister this schema with the schema registry. Get this registered schema using the EventLogger.schema.get() method. N)r>registerrH _modifiersset_modified_listeners_unmodified_listeners)r;schema event_schemakeys r"register_event_schema!EventLogger.register_event_schemas~ ||,,V4 oo oo %#&5DOOC .. .,/ED $ $S ) 00 0.1eD & &s + 1r!c^SU4Sjjn[US9nURU5 TRRU5 UTR;aTRR U5 gg)zoRegister a new logging handler to the Event Logger. All outgoing messages will be formatted as a JSON string. c>TRRUS5nSUR;aUS [R"U40UD6$)a Python's logger always emits the "message" field with the value as "null" unless it's present in the schema/data. Message happens to be a common field for event logs, so special case it here and only emit it if "message" is found the in the schema's property list. __schema__message)r>get propertiesjsondumps)recordrRrkr;s r"_handle_message_field;EventLogger.register_handler.._handle_message_fieldsH\\%%f\&:;F 1 119%::f// /r!)json_serializerN)rxt.AnyrRr|r]rG)r setFormatterrK addHandlerrOappend)r;rTry formatters` r"rPEventLogger.register_handlers\ 0"1  Y' ( $-- ' MM  ) (r!cURRU5 XR;aURRU5 gg)z>Remove a logging handler from the logger and list of handlers.N)rK removeHandlerrOremove)r;rTs r"remove_handlerEventLogger.remove_handlers5 ""7+ mm # MM  ) $r!) schema_idcJ[U5(d Sn[U5eU(aDURRU[ 55nUR U5 X@RU'gURH+nUbXQ:XdM URUR U5 M- g)aAdd a modifier (callable) to a registered event. Parameters ---------- modifier: Callable A callable function/method that executes when the named event occurs. This method enforces a string signature for modifiers: (schema_id: str, data: dict) -> dict: z`modifier` must be a callableN)callable TypeErrorrgrtrhadd)r;rmodifiermsg modifiersid_s r" add_modifierEventLogger.add_modifiers"!!1CC.  ++Isu=I MM( #)2OOI & ??C C$4$((2#r!cU(aURURU5 gURRH?nURURU5 URURU5 MA g)zRemove a modifier from an event or all events. Parameters ---------- schema_id: str If given, remove this modifier only for a specific event type. modifier: Callable[[str, dict], dict] The modifier to remove. N)rgdiscardr> schema_ids)r;rrs r"remove_modifierEventLogger.remove_modifiersb"  OOI & . .x 8"\\44  *228< *228<5r!)modifiedrcB[U5(d Sn[U5eU(aU(aDURRU[ 55nUR U5 XPRU'gUR RU[ 55nUR U5 XPR U'gURRHRnUbXb:XdM U(a URUR U5 M4UR UR U5 MT g)aEAdd a listener (callable) to a registered event. Parameters ---------- modified: bool If True (default), listens to the data after it has been mutated/modified by the list of modifiers. schema_id: str $id of the schema listener: Callable A callable function/method that executes when the named event occurs. z`listener` must be a callableN) rrrirtrhrrjr>r)r;rrlistenerr listenersrs r" add_listenerEventLogger.add_listeners&!!1CC.  !4488CEJ  h'6?((32266y#%HI MM( #4= & &y 1 <<**C C$4,,S155h?..s377A +r!c>U(a=URURU5 URURU5 gURRH?nURURU5 URURU5 MA g)zRemove a listener from an event or all events. Parameters ---------- schema_id: str If given, remove this modifier only for a specific event type. listener: Callable[[EventLogger, str, dict], dict] The modifier to remove. N)rirrjr>r)r;rrs r"remove_listenerEventLogger.remove_listener,s"   $ $Y / 7 7 A  & &y 1 9 9( C"\\44 ((3;;HE**95==hG5r!)timestamp_overridec F^TR(dATRRU5(d!TRRU5(dgUTR;a[ R "US3[SS9 gTRRU5n[R"U5nTRURH nU"XS9nM TRUR(aTRRX5 TRRX5 Uc"[R"[R S9OUnUR#5S-UUR$[&S.n[(R*"U5 UR1U5 TR2R5U5 S U4S jjn TRUHKn [6R8"U "TUUS 95n TR:R=U 5 U R?U 5 MM TRUHRn [6R8"U "TXS 95n TR:R=U 5 S U4S jjn U R?U 5 MT U$![,a n [.U eSn A ff=f) aB Record given event with schema has occurred. Parameters ---------- schema_id: str $id of the schema data: dict The event to record timestamp_override: datetime, optional Optionally override the event timestamp. By default it is set to the current timestamp. Returns ------- dict The recorded event data Nz has not been registered yet. If this was not intentional, please register the schema using the `register_event_schema` method.) stacklevel)rdata)tzZ) __timestamp__rr__schema_version____metadata_version__c>UR5nU(aTRRU5 TRR U5 gr@ exceptionlogerrorr5rtaskerrr;s r"_listener_task_done-EventLogger.emit.._listener_task_dones8.."Cs#  " " * *4 0r!)loggerrrc>UR5nU(aTRRU5 TRR U5 gr@rrs r"rrs8nn&HHNN3'&&..t4r!)rzasyncio.Task[t.Any]r]None) rOrirtrjr>warningswarnrcopydeepcopyrgrHvalidate_eventrnowrutc isoformatrEVENTS_METADATA_VERSIONrvalidaterr(updaterKinfor8 create_taskr5radd_done_callback) r;rrrrk modified_datar timestampcapsulerrrrs ` r"emitEventLogger.emitGsL, ,,00;;..229== DLL ( MM+22$  !!), d+  2H$yMM3  % %fii 0 LL ' ' 8 ##I=.@-GHLLHLL )M_ '002S8#"(..$;    - ) 2 27 ; }% '" 100;H&&'&D  " " & &t ,  " "#6 7<229=H&&xty'\]D  " " & &t , 5  " "#6 7> c -# , -s;J J JJ )rK)r]z list[t.Any])r]r)rQr|rRr|r]r)NN)rar r[list[str] | Noner\rr]r)rkrr]r)rTzlogging.Handlerr]r)r str | Nonerz5t.Callable[[str, dict[str, t.Any]], dict[str, t.Any]]r]r)rboolrrrQt.Callable[[EventLogger, str, dict[str, t.Any]], t.Coroutine[t.Any, t.Any, None]]r]r)rrrrr]r)rrGrzdict[str, t.Any]rzdatetime | Noner]zdict[str, t.Any] | None)!rrrrrrtagrOr rr>r rgrirjr r5__annotations__r<r rArFr`rnrPrrrrrrr __classcell__)rUs@r"r/r/@s  cc  GbQRJr(cd  R36%/7U Y  /*+/#' O O(O! O  OO,4 *4*!% 3 3H 3  3J!%==H =  =: $ *B*B *B d *B  *B^!%HHd H  H8`dss'7sM\s ssr!r/)/r __future__rr8rrvrItypingtrrrimportlib.metadatar jsonschemarpackaging.versionr traitletsr r r r traitlets.configr rrkrschema_registryrr\r validatorsr version_infopythonjsonlogger.jsonrpythonjsonlogger.jsonloggerrWarningr Exceptionr%r( simplefilterr,r/rr!r"rs# '&&#228+5+, %.(39' I E E  f12I z%zr!