\R~r@\cn[R"S5nSRSUSSUSS455$)zGenerate a new random id. Avoids problematic runtime import in stdlib uuid on Python 2. Returns ------- id string (16 random bytes as hex-encoded text, chunks separated by '-') -c3V# UHn[U5RS5v M! g7f)asciiN)rrH).0xs r0 new_id..s$K8J1GAJ%%g..8Js')N)osurandomjoin)bufs r0new_idr_s7 **R.C 88KRa#ab'8JK KKr1c4[5RS5$)zReturn new_id as ascii bytesrU)r_r+r1r0 new_id_bytesrbs 8??7 ##r1zSession.sessionzSession.usernamezSession.keyfile)identuserkeyfileSession)r-rezUse HMAC digests for authentication of messages. Setting this flag will generate a new UUID to use as the HMAC key. r1zDon't authenticate messages.)securez no-securec[R"S[SS9 SU;a!SUR;dSUR;ag[ 5URlg)zSet the default behavior for a config environment to be secure. If Session.key/keyfile have not been set, set Session.key to a new random UUID. zdefault_secure is deprecatedr9r:rfr-reN)r@rADeprecationWarningrfrbr-)cfgs r0default_securerlsE  MM02DQRSCUckk1Y#++5M"nCKKOr1c6[R"[5$)z#Return timezone-aware UTC timestamp)rnowutcrar1r0utcnowrps << r1c^\rSrSrSr\"S5r\"S5SSj5r\ "S5r SSjr \ "SS S 9r \ "S 5r SS jrSU4S jjrSrU=r$)SessionFactoryzSThe Base class for configurables that have a Session, Context, logger, and IOLoop. rglognamec@[R"US5Ulg)Nnew)logging getLoggerlogselfchanges r0_logname_changedSessionFactory._logname_changeds$$VE]3r1 zmq.Contextc,[R"5$N)zmqContextr{s r0_context_defaultSessionFactory._context_defaults{{}r1zjupyter_client.session.SessionT allow_noneztornado.ioloop.IOLoopc,[R"5$r)rcurrentrs r0 _loop_defaultSessionFactory._loop_defaults~~r1c b>[TU]"S0UD6 URc[S0UD6Ulgg)zInitialize a session factory.Nra)super__init__sessionrfr{kwargs __class__s r0rSessionFactory.__init__s1 "6" << ",V,DL r1)ryrr|t.AnyreturnNone)rr)rrrrrr)__name__ __module__ __qualname____firstlineno____doc__rrtrr}rcontextrrlooprr__static_attributes__ __classcell__rs@r0rrrrsdbkG Y44}%G7DIG + ,D --r1rrcT\rSrSrSrS SjrS SjrS SjrS SjrSSjr SSjr S r g )MessagezA simple message object that maps dict keys to attributes. A Message can be created from a dict and a dict from a Message instance simply by calling dict(msg_obj).cURn[U5R5H)up4[U[5(a [ U5nXBU'M+ g)zInitialize a message.N)__dict__r$itemsr#r)r{msg_dictdctkr/s r0rMessage.__init__sAmmN((*DA!T""AJF+r1cH[URR55$r)iterrrrs r0__iter__Message.__iter__sDMM'')**r1c,[UR5$r)reprrrs r0__repr__Message.__repr__sDMM""r1cB[R"UR5$r)pprintpformatrrs r0__str__Message.__str__s~~dmm,,r1cXR;$rrr{rs r0 __contains__Message.__contains__ sMM!!r1c URU$rrrs r0 __getitem__Message.__getitem__ s}}Qr1raN)rdict[str, t.Any]rr)rzt.ItemsView[str, t.Any]rr()robjectrbool)rr(rr) rrrrrrrrrrrrrar1r0rrs%( +#-" r1rc6[5n[n[5$)zCreate a new message header)rprlocals)msg_idmsg_typeusernamerdateversions r0 msg_headerrs 8DG 8Or1cU(d0$USn[U[5(d [U5nU$![a USnUnN6![a ef=ff=f)z-Given a message or header, return the header.headerr)KeyErrorr#r$) msg_or_headerhs r0extract_headerrsq    ( # a   G H  h'AA    s 2 AAA AAcz^\rSrSrSr\"SSSS9r\"SSSS9r\"SSS S9r \ "S 5SCS j5r \"SSS S9r \ "S 5SCSj5r \"SSSS9rSDSjr\ "S5SCSj5r\"S5r\"\R,R/SS5SSS9r\"0SSS9r\"S5r\"SSS9rSESjr\ "S5SCSj5r\"SSS S9r \ "S!5SCS"j5r!\""5r#SFS#jr$\%"\&RNSS$9r(SGS%jr)\*"5r+\"S&SS'S9r,\"SSS(S9r-\ "S)5SCS*j5r.\"5r/\""\05r1\ "S+5SCS,j5r2\""\35r4\ "S-5SCS.j5r5\"S&SS/S9r6\"\7SS0S9r8\"\9SS1S9r:SHU4S2jjr;SIS3jrSDS4j5r?SGS5jr@SJS6jrASKSLS7jjrBSMS8jrCSNSOS9jjrDSPSQS:jjrESRSSS;jjrF\GRSS4STS<jjrISUSVS=jjrJSWS>jrKSGS?jrLSXSYS@jjrMSZSAjrNSBrOU=rP$)[rfi-aObject for handling serialization and sending of messages. The Session object handles building messages and sending them with ZMQ sockets or ZMQStream objects. Objects can communicate with each other over the network via Session objects, and only need to work with the dict-based IPython message spec. The Session will handle serialization/deserialization, security, and metadata. Sessions support configurable serialization via packer/unpacker traits, and signing with HMAC digests via the key/keyfile traits. Parameters ---------- debug : bool whether to trigger extra debugging statements packer/unpacker : str : 'json', 'pickle' or import_string importstrings for methods to serialize message parts. If just 'json' or 'pickle', predefined JSON and pickle packers will be used. Otherwise, the entire importstring must be used. The functions must accept at least valid JSON input, and output *bytes*. For example, to use msgpack: packer = 'msgpack.packb', unpacker='msgpack.unpackb' pack/unpack : callables You can also set the pack/unpack callables for serialization directly. session : bytes the ID of this Session object. The default is to generate a new UUID. username : unicode username added to message headers. The default is to ask the OS. key : bytes The key used to initialize an HMAC signature. If unset, messages will not be signed or checked. keyfile : filepath The file containing a key. If this is set, `key` will be initialized to the contents of the file. FTzDebug output in the Session)confighelpzWhether to check PID to protect against calls after fork. This check can be disabled if fork-safety is handled elsewhere. r<zThe name of the packer for serializing messages. Should be one of 'json', 'pickle', or an import name for a custom callable serializer.packercUSnUR5S:Xa[Ul[UlX lgUR5S:Xa[ Ul[UlX lg[[U55UlgNrvr<rM) lowerrDpackrKunpackunpackerrPpickle_unpackerrr(r{r|rvs r0_packer_changedSession._packer_changedis]Um 99;& #DI'DKM YY[H $%DI)DKM#CH-DIr1zjThe name of the unpacker for unserializing messages. Only used with custom functions for `packer`.rcUSnUR5S:Xa[Ul[UlX lgUR5S:Xa[ Ul[UlX lg[[U55Ulgr) rrDrrKrrrPrrr(rs r0_unpacker_changedSession._unpacker_changed~s]Um 99;& #DI'DKK YY[H $%DI)DKK%c#h/DKr1rgz"The UUID identifying this session.cF[5nURS5UlU$NrU)r_r+bsession)r{us r0_session_defaultSession._session_defaults H) r1rcDURRS5Ulgr)rr+rrzs r0_session_changedSession._session_changeds ++G4 r1r1USERrz:Username for the Session. Default is your system username.)rrzZMetadata dictionary, which serves as the default top-level metadata dict for each message.rz$execution key, for signing messages.c[5$r)rbrs r0 _key_defaultSession._key_defaults ~r1r-c$UR5 gr) _new_authrzs r0 _key_changedSession._key_changeds  r1z hmac-sha256zcThe digest scheme used to construct the message signatures. Must have the form 'hmac-HASH'.signature_schemecUSnURS5(d[SU-5eURSS5Sn[[U5UlUR5 g![ an[SU-5UeSnAff=f)Nrvzhmac-z0signature_scheme must start with 'hmac-', got %rrSrz!hashlib has no such attribute: %s) startswithrsplitgetattrhashlib digest_modAttributeErrorr)r{r|rv hash_namerBs r0_signature_scheme_changed!Session._signature_scheme_changedsUm~~g&&ORUUV VIIc1%a(  U%gy9DO  U@9LMST T UsA&& B0A??Bc"[R$r)rsha256rs r0_digest_mod_defaultSession._digest_mod_defaults ~~r1rcUR(a/[R"URURS9UlgSUlg)N) digestmod)r-hmacHMACrauthrs r0rSession._new_auths* 88 $((dooFDIDIr1izzThe maximum number of digests to remember. The digest history will be culled when it exceeds this value. z&path to file containing execution key.rec[USS5nUR5R5UlSSS5 g!,(df  g=f)Nrvrb)openreadstripr-)r{r|fs r0_keyfile_changedSession._keyfile_changeds2 &- &!vvx~~'DH' & &s $= A rc\USn[U5(d[S[U5-5eg)Nrvzpacker must be callable, not %scallabler>typers r0 _pack_changedSession._pack_changeds.Um}}=S IJ Jr1rc\USn[U5(d[S[U5-5eg)Nrvz!unpacker must be callable, not %srrs r0_unpack_changedSession._unpack_changeds0Um}}?$s)KL Lr1zJThreshold (in bytes) beyond which a buffer should be sent without copying.z[Threshold (in bytes) beyond which an object's buffer should be extracted to avoid pickling.zThe maximum number of items for a container to be introspected for custom serialization. Containers larger than this are pickled outright. c 4>[TU]"S0UD6 UR5 UR05UlUR [ R"5UlUR5 UR(d[5RS5 gg)aUcreate a Session object Parameters ---------- debug : bool whether to trigger extra debugging statements packer/unpacker : str : 'json', 'pickle' or import_string importstrings for methods to serialize message parts. If just 'json' or 'pickle', predefined JSON and pickle packers will be used. Otherwise, the entire importstring must be used. The functions must accept at least valid JSON input, and output *bytes*. For example, to use msgpack: packer = 'msgpack.packb', unpacker='msgpack.unpackb' pack/unpack : callables You can also set the pack/unpack callables for serialization directly. session : unicode (must be ascii) the ID of this Session object. The default is to generate a new UUID. bsession : bytes The session as bytes username : unicode username added to message headers. The default is to ask the OS. key : bytes The key used to initialize an HMAC signature. If unset, messages will not be signed or checked. signature_scheme : str The message digest scheme. Currently must be of the form 'hmac-HASH', where 'HASH' is a hashing function available in Python's hashlib. The default is 'hmac-sha256'. This is ignored if 'key' is empty. keyfile : filepath The file containing a key. If this is set, `key` will be initialized to the contents of the file. zCMessage signing is disabled. This is insecure and not recommended!Nra) rr_check_packersrnonerr[getpidpidrr-rwarningrs r0rSession.__init__snP "6" IIbM  99; xx L U r1c [U5"5nUR5Hn[X[X55 M [ 5UlUR R UR 5 U$)zCreate a copy of this Session Useful when connecting multiple times to a given kernel. This prevents a shared digest_history warning about duplicate digests due to multiple connections to IOPub in the same process. .. versionadded:: 5.1 )rtraitssetattrrsetdigest_historyupdate)r{ new_sessionnames r0clone Session.cloneDsZ4jl KKMD Kwt': ;"&)U """))$*=*=>r1cURnU=RS- slURS[R"5SU3$)Nr_) message_countrr[r )r{message_numbers r0rSession.msg_idXs@++ a,,q Q~.>??r1cv^^URmURmSSS/0nT"U5n[ U[ 5(d[ S[U5-5eT"U5nXQ:XdeS [50nT"T"U55n[ US [5(a S n[ U5eg![a#nSURSU3n[ U5UeSnAff=f![a0nSURS URS U3n[ U5UeSnAff=f![a U4S jUlU4SjUlgf=f)z#check packers for datetime support.arhizpacker 'z(' could not serialize a simple message: Nz,message packed to %r, but bytes are requiredz unpacker 'z'' could not handle output from packer 'z': tz!Shouldn't deserialize to datetimec&>T"[U55$r)r )rOrs r0(Session._check_packers..s$|A"7r1c>T"U5$rra)rJrs r0r8r9s F1Ir1) rr Exceptionrr?r#rGrrrpr) r{msg_listrCrBmsgunpacked msg_datetimerrs @@r0rSession._check_packers^sUyy!T# )(^F &%((KdSYlZ[ [ )f~H' ''VX  .d<01H(3-229 o%3/ )T[[M)QRSQTUCS/q ( ) )T]]O,[[MQC) S/q (  ) .7DI-DK .sAB(C43D( C2CC D"+D  D D87D8cX[URXRUR5$)z#Create a header for a message type.)rrrr)r{rs r0rSession.msg_headers$++x MMr1c0nUcURU5OUnXFS'USUS'USUS'Uc0O [U5US'Uc0OUUS'URR5US'UbUSR U5 U$)zReturn the nested message dict. This format is different from what is sent over the wire. The serialize/deserialize methods converts this nested message dict to the wire format, which is a list of message parts. rrr parent_headercontentmetadata)rrrFcopyr))r{rrEparentrrFr=s r0r= Session.msgs.4n*&H x(H  ,J%+^r9OO&GI--,,.J    O " "8 , r1cURcgURR5nUHnURU5 M UR5R 5$)zSign a message with HMAC digest. If no auth, return b''. Parameters ---------- msg_list : list The [p_header,p_parent,p_content] part of the message list. r1)r rGr) hexdigestr+)r{r<rms r0sign Session.signsK 99  IINN A HHQK{{}##%%r1cURS05nUc URnO{[U[5(aUR U5nOT[U[ 5(aO>[U[ 5(aURS5nO[S[U5-5eUR US5UR US5UR US5U/n/n[U[5(aURU5 OUbURU5 UR[5 URU5nURU5 URU5 U$)aSerialize the message components to bytes. This is roughly the inverse of deserialize. The serialize/deserialize methods work with full message lists, whereas pack/unpack work with the individual message parts in the message list. Parameters ---------- msg : dict or Message The next message dict as returned by the self.msg method. Returns ------- msg_list : list The list of bytes objects to be sent with the format:: [ident1, ident2, ..., DELIM, HMAC, p_header, p_parent, p_metadata, p_content, buffer1, buffer2, ...] In this list, the ``p_*`` entities are the packed or serialized versions, so if JSON is used, these are utf8 encoded JSON strings. rEr"zContent incorrect type: %srrDrF)getrr#r$rrGr(r+r>rr%extendappendDELIMrM)r{r=rcrE real_messageto_send signatures r0 serializeSession.serializes#6'')R( ?iiG  & &ii(G  ' '   % %nnV,G84=HI I IIc(m $ IIc/* + IIc*o &    eT " " NN5 !   NN5 !uIIl+ y!|$r1c [U[R5(dSn[U[RR5(a.Uce[RR UR 5n[U[ [45(aUn U=(d U RS/5nOURUUUUU S9n UR(a>[R"5UR:wa[5RSU 5 gUc/OUn[!U5H\up[U ["5(aU n O [#U 5n ['U S5(dM<U R((aMO[+SX4-5e UR,(a[/XR,5n UR1X5nUR3U5 [5UVs/sHn[7U5PM sn5nUUR8:nU(a'U(a U(aU(dUR;USS S 9nO$U(a[<nUR;UUS 9 O[<nUR>(aB[@R@"U 5 [@R@"U5 [@R@"U5 UU S 'U $![$anSn[%U5UeSnAff=fs snf) aGBuild and send a message via stream or socket. The message format used by this function internally is as follows: [ident1,ident2,...,DELIM,HMAC,p_header,p_parent,p_content, buffer1,buffer2,...] The serialize/deserialize methods convert the nested message dict into this format. Parameters ---------- stream : zmq.Socket or ZMQStream The socket-like object used to send the data. msg_or_type : str or Message/dict Normally, msg_or_type will be a msg_type unless a message is being sent more than once. If a header is supplied, this can be set to None and the msg_type will be pulled from the header. content : dict or None The content of the message (ignored if msg_or_type is a message). header : dict or None The header dict for the message (ignored if msg_to_type is a message). parent : Message or dict or None The parent or parent header describing the parent of this message (ignored if msg_or_type is a message). ident : bytes or list of bytes The zmq.IDENTITY routing path. metadata : dict or None The metadata describing the message buffers : list or None The already-serialized buffers to be appended to the message. track : bool Whether to track. Only for use with Sockets, because ZMQStream objects cannot track messages. Returns ------- msg : dict The constructed message. FNbuffers)rErHrrFz/WARNING: attempted to send message from fork %sz0Buffer objects must support the buffer protocol. contiguousz Buffer %i (%r) is not contiguousT)rGtrackrGtracker)!r#rSocketasyncioshadow underlyingrr$rPr= check_pidr[r r!rr"r* memoryviewr>hasattrr[r? adapt_versionrrWrQmaxlencopy_thresholdsend_multipartDONEdebugr)r{stream msg_or_typerErHrcrZr\rrFr=idxr^viewrBemsgrUrJlongestrGr^s r0send Session.sendsAn&#**--E fckk00 1 1% %%ZZ&&v'8'89F kGT? 3 3C7B!7G((! C >>biikTXX5 L !SUX Y"W!'*HC#z**1%c?D t\**4??? !Csj!PQQ+   //0C..,ww/w!s1vw/0,,, g%++G%t+LG G  ! !' ! 5G :: MM#  MM' " MM' " I C!1MD#D/q010s J.K. K 8KK c/n[U[5(aU/nUbURU5 UR[5 URUR USS55 URU5 [U[ RR5(a)[ RRUR5nURXcUS9 g)aSend a raw message via ident path. This method is used to send a already serialized message. Parameters ---------- stream : ZMQStream or Socket The ZMQ stream or socket to use for sending the message. msg_list : list The serialized list of messages to send. This only includes the [p_header,p_parent,p_metadata,p_content,buffer1,buffer2,...] portion of the message. ident : ident or list A single ident or a list of idents to use in sending. NrrZr]) r#rGrQrRrSrMrr`r_rarbrj)r{rmr<flagsrGrcrUs r0send_rawSession.send_rawls. eU # #GE   NN5 !utyy!A/0x fckk00 1 1ZZ&&v'8'89Fg48r1c[U[5(a URn[U[RR 5(a)[R R UR5nURX$S9nURXT5upuXpRXSUS94$![Ra)nUR[R:XaSnAgeSnAff=f![anUeSnAff=f)a Receive and unpack a message. Parameters ---------- socket : ZMQStream or Socket The socket or stream to use in receiving. Returns ------- [idents], msg [idents] is a list of idents and msg is a nested message dict of same format as self.msg returns. r]N)NN)rErG)r#rsocketrr`r_rarbrecv_multipartZMQErrorerrnoEAGAINfeed_identities deserializer;)r{rzmoderErGr<rBidentss r0recv Session.recvs( fi ( (]]F fckk00 1 1ZZ&&v'8'89F ,,T,=H //? ++HD+QQ Q|| ww#**$"   G s65B)C))C&=C! C!!C&) C:3C55C:c U(aM[R"[R[U5nUR [ 5nUSUXS-S4$[R"[R[ RU5nSn[U5Hup5UR[ :XdMSn O U(a Sn[U5eUSWXS-SpUVs/sHn[UR5PM snU4$s snf)aSplit the identities from the rest of the message. Feed until DELIM is reached, then return the prefix as idents and remainder as msg_list. This is easily broken by setting an IDENT to DELIM, but that would be silly. Parameters ---------- msg_list : a list of Message or bytes objects The message to be split. copy : bool flag determining whether the arguments are bytes or Messages Returns ------- (idents, msg_list) : two lists idents will always be a list of bytes, each of which is a ZMQ identity. msg_list will be a list of bytes or zmq.Messages of the form [HMAC,p_header,p_parent,p_content,buffer1,buffer2,...] and should be unpackable/unserializable via self.deserialize at this point. NrTFzDELIM not in msg_list) r6castListrGindexrSrrr*r?)r{r<rGrofailedrLr=rs r0rSession.feed_identitiess2 vvaffUmX6H..'CDS>8!GI#66 6vvaffS[[18&> >  % % ' ?r1c<[UR5n[[US-5XR- 5nX!:a[ 5Ulg[ R"[[UR55U5nURRU5 g)zOcull the digest history Removes a randomly selected 10% of the digest history N) rhr(rgintrr'randomsampletuplesorteddifference_update)r{r n_to_cullto_culls r0rSession._cull_digest_historysy d))*GrM*G6N6N,NO  "%%D  --fT-@-@&A BIN --g6r1cSn0nU(d[R"[R[RU5nUSUVs/sHn[ UR 5PM nn[R"[R[ U5nXqUS-n[R"[R[ U5nUR bUSnU(d Sn[U5eXR;a[SU-5eU(aURU5 URUSS5n [X5(dSU-n[U5e[U5U:dSU-n[U5eURUS5n [U 5US 'U S US 'U S US '[URUS 55US 'URUS5US'U(aURUS5US'OUSUS'USSV s/sHn [!U 5PM n n U (awU SR"cg[R"[R[RU5nUSSV s/sH!n [![ U R 55PM# n n XS'UR$(a[&R&"U5 [)U5$s snfs sn fs sn f)a'Unserialize a msg_list to a nested message dict. This is roughly the inverse of serialize. The serialize/deserialize methods work with full message lists, whereas pack/unpack work with the individual message parts in the message list. Parameters ---------- msg_list : list of bytes or Message objects The list of message parts of the form [HMAC,p_header,p_parent, p_metadata,p_content,buffer1,buffer2,...]. content : bool (True) Whether to unpack the content dict (True), or leave it packed (False). copy : bool (True) Whether msg_list contains bytes (True) or the non-copying Message objects in each place (False). Returns ------- msg : dict The nested message dict with top-level keys [header, parent_header, content, buffers]. The buffers are returned as memoryviews. NrzUnsigned MessagezDuplicate Signature: %rrzInvalid Signature: %rz1malformed message, must have at least %i elementsrrrr9rDrFrZrErZ)r6rrrrrGr r?r(rrMrrhr>rrrdshaperlrr) r{r<rErGminlenmessager=msg_list_beginningrVcheckrbrZs r0rSession.deserializes<vvaffS[[18Fw>O!P>Os% "2>O !PvvaffUmX6H)VW,==H66!&&-2 99   I( o%/// !:Y!FGG  +IIhqm,E!)33- 9 o%8}&ENCC. Xa[))&1"8,$Z0 #0Xa[1I#J "kk(1+6  !%Xa[!9GI !)!GI *212,7,Q:a=,7 wqz''/vvaffS[[188Is KK9(K#cZ[R"S[SS9 UR"U0UD6$)z'**DEPRECATED** Use deserialize instead.z;Session.unserialize is deprecated. Use Session.deserialize.r9r:)r@rArjr)r{argsrs r0 unserializeSession.unserializeKs1  I  000r1) r rr(rr-rrrr!rrrrrrG)rz t.Callable)rrr)rrf)rr(rr)NNNN) rr(rEz dict | NonerHdict[str, t.Any] | NonerrrFrrr)r<r%rrGr)r=rrczlist[bytes] | bytes | Nonerz list[bytes])NNNNFNN)rmz*zmq.sugar.socket.Socket | ZMQStream | Nonernzdict[str, t.Any] | strrErrHrrcbytes | list[bytes] | NonerZzlist[bytes] | Noner\rrrrFrrr)rTN) rmzmq.sugar.socket.Socketr<r%rvrrGrrcrrr) rzrrrrErrGrrz2tuple[list[bytes] | None, dict[str, t.Any] | None])T)r<list[bytes] | list[zmq.Message]rGrrz3tuple[list[bytes], list[bytes] | list[zmq.Message]])rVrGrr)TT)r<rrErrGrrr)rrrrrr)Qrrrrrr rlrcrrrrrrr rrrr rrr[environrPrr rFrrfr-rrrrr rrrrr r rrr(rrerr!default_packerrrdefault_unpackerrrri MAX_BYTESbuffer_threshold MAX_ITEMSitem_thresholdrr,r0propertyrrrr=rMrWrsrwrNOBLOCKrrrrrrrrrs@r0rfrf-s&P t*K LE  I1F X . . 9H Z 0 0r$-UVG  Y55c{H vz* MH  HAJM #M NC U^+   ! J DII$ /D UN!  b,XYG Y(( )C ~ D V_KK ! "F XMM  YN   N2h$M @@ %.NN $*.*.,0 (  (  *  4 &$-1> >*>  >H,0*.,0&**.,0x:x,x) x ( x * x$xx(x*x !x|,0 #9'#9#9 #9  #9 * #9 #9PKK )')) )  ) < )XGK(>7(>?C(> <(>T ( 7  K1KK K  KZ11r1)r,rrr)r,rrrG)rJz str | bytesrr)rOrrrGrr)rkrrr)rr) rr(rr(rr(rz Session | strrr)rrrr)Qr __future__rrrr<rwr[rMrrtypingr6r@binasciirrrr zmq.asynciortornado.ioloopr traitletsr r r r r rrrrrrrtraitlets.config.configurablerr traitlets.logrtraitlets.utils.importstringrzmq.eventloop.zmqstreamr_versionradapterrjsonutilrrrr DEFAULT_PROTOCOLrNror'rrrDrKrPrIrrrrSMessageTrackerrkr_rbsession_aliases session_flagsrlrprrrrrrfrar1r0rs #  '!    L$4-&KK))ll (   8: ,,   L$    LNr:;  CB/0*   %-(-B  > *-8E (f 1lf 1r1