^hNDSrSSKrSSKrSSKrSSKJrJrJrJrJ r \"S\ 5r \"S\ 5r SSK r SSKJrJr SSKJr SS KJr SS KJrJrJrJr SS KJr SS KJ r "S S\!5r"\"SS55r#"SS5r$"SS\5r%g!\a SSKJr Njf=f)zA base class session manager.N)AnyNewTypeOptionalUnioncast KernelName ModelName)dbapi2) dataclassfields) ensure_async)web)Instance TraitErrorUnicodevalidate)LoggingConfigurable)InstanceFromClassesc\rSrSrSrSrg)KernelSessionRecordConflictz_Exception class to use when two KernelSessionRecords cannot merge because of conflicting data. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__ri/home/james-whalen/.local/lib/python3.13/site-packages/jupyter_server/services/sessions/sessionmanager.pyrrsrrc^\rSrSr%SrSr\\\S'Sr \\\S'S\ S\ 4Sjr S S jr S rg) KernelSessionRecord#zA record object for tracking a Jupyter Server Kernel Session. Two records that share a session_id must also share a kernel_id, while kernels can have multiple session (and thereby) session_ids associated with them. N session_id kernel_idotherreturnc[U[5(aUR=(a URUR:Hn[URUR:HURSL=(d URSL/5n[ X#/5(ag[URURUR:HURUR:g/5(a Sn[ U5eg)z Whether a record equals another.NTzA single session_id can only have one kernel_id associated with. These two KernelSessionRecords share the same session_id but have different kernel_ids. This should not be possible and is likely an issue with the session records.F) isinstancer"r%allr$anyr)selfr& condition1 condition2msgs r __eq__KernelSessionRecord.__eq__/s e0 1 1MDNNeoo,MJOOu'7'77NNd*Eeoo.EJ J+,,OOOOu'7'77NNeoo52#66rc [U[5(d Sn[U5eUR(a8UR(a'URUR:wa Sn[ U5e[ U5Hdn[ XR5(dM[XR5(dM;[XR[XR55 Mf g)zCUpdates in-place a kernel from other (only accepts positive updatesz3'other' must be an instance of KernelSessionRecord.zJCould not update the record from 'other' because the two records conflict.N) r)r" TypeErrorr%rr hasattrnamegetattrsetattr)r,r&r/fields r updateKernelSessionRecord.updateOs%!455GCC. ??t~~%//T^^2S^C-c2 2D\Eujj))geZZ.H.Hjj'%*DE"rr)r&r"r'N)rrrrrr$rstr__annotations__r%objectboolr0r9rrrr r"r"#s?!%J $#Ix}#Ft@ Frr"c\rSrSr%Sr\\\S'S\4SjrSr S\ \\ 4S\ 4S jr S rS\ \\ 4S\4S jrS\SS 4S jrS\SS 4SjrSrg )KernelSessionRecordList^aAn object for storing and managing a list of KernelSessionRecords. When adding a record to the list, the KernelSessionRecordList first checks if the record already exists in the list. If it does, the record will be updated with the new information; otherwise, it will be appended. _recordsrecordscF/UlUHnURU5 M gzInitialize a record list.N)rBr9)r,rCrecords r __init__ KernelSessionRecordList.__init__is F KK rc,[UR5$)z+The string representation of a record list.)r;rBr,s r __str__KernelSessionRecordList.__str__o4==!!rrFr'c[U[5(aXR;ag[U[5(a0URH nXRUR 4;dM g g)z.Search for records by kernel_id and session_idTF)r)r"rBr;r$r%)r,rFrs r __contains__$KernelSessionRecordList.__contains__ssR f1 2 2v7N fc " "]]llAKK88#rc,[UR5$)zThe length of the record list.)lenrBrJs r __len__KernelSessionRecordList.__len__~rMrc[U[5(a3URH"nXRUR4;dM Us $ O1[U[ 5(aURH nX:XdM Us $ US3n[ U5e)zcReturn a full KernelSessionRecord from a session_id, kernel_id, or incomplete KernelSessionRecord. z& not found in KernelSessionRecordList.)r)r;rBr%r$r" ValueError)r,rFrOr/s r getKernelSessionRecordList.getsx fc " "]]kk1<<88H# 3 4 4]];!M#>?orNcURRU5nURURU5 g![a URR U5 gf=f)z9Update a record in-place or append it if not in the list.N)rBindexr9rWappend)r,rFidxs r r9KernelSessionRecordList.updatesS )--%%f-C MM#  % %f - ) MM  ( )s9<%A$#A$cZXR;aURRU5 gg)zIRemove a record if its found in the list. If it's not found, do nothing. N)rBremove)r,rFs r r`KernelSessionRecordList.removes% ]] " MM  ( #r)rB)rrrrrlistr"r<rGrKrr;r>rPrTrXr9r`rrrr r@r@^s&'' !4 " 5)Q )0)T))0)T)rr@c^\rSrSrSr\"SSS9R SS9r\"S5S 5r \ "S 5r \ "S S /5r U4S jrSrSr1Skr\S5r\S5rSrSrSrS\4SjrS(S\\S\\S\\S\\S\\S\\\44 SjjrS)S\\S\\S\\\44Sjjr S\S\\S\\S\\S\\S\4 Sjr!S*S jr"S!r#S"r$S\S\%4S#jr&S+S$jr'S%r(S&r)S'r*U=r+$),SessionManagerzA session manager.:memory:zThe filesystem path to SQLite Database file (e.g. /path/to/session_database.db). By default, the session database is stored in-memory (i.e. `:memory:` setting from sqlite3) and does not persist when the current Jupyter Server shuts down.) default_valuehelpT)configdatabase_filepathczUSnUS:XaU$[R"U5nUR5(aqUR5(a Sn[ U5e[ US5nUR S5nSSS5 WRS5(dUS:wa S n[ U5eU$!,(df  N9=f) zValidate a database file path.valuerfzL`database_filepath` expected a file path, but the given path is a directory.rbdNsSQLite format 3rz.The given file is not an SQLite database file.)pathlibPathexistsis_dirropenread startswith)r,proposalrlpathr/fheaders r _validate_database_filepath*SessionManager._validate_database_filepaths! J L||E" ;;=={{}}d o%eT"a#$$%788Vs]F o% #"s 'B,, B:zBjupyter_server.services.kernels.kernelmanager.MappingKernelManagerz8jupyter_server.services.contents.manager.ContentsManagerz2notebook.services.contents.manager.ContentsManagercD>[TU]"U0UD6 [5UlgrE)superrGr@_pending_sessions)r,argskwargs __class__s r rGSessionManager.__init__s  $)&)!8!:rN>r5rwtyper%r$cURc:URR5UlURRS5 UR$)z5Start a cursor and create a database called 'session'z\CREATE TABLE IF NOT EXISTS session (session_id, path, name, type, kernel_id))_cursor connectioncursorexecuterJs r rSessionManager.cursorsE << ??113DL LL = ||rcURcC[R"URSS9Ul[RURlUR$)zStart a database connectionN)isolation_level) _connectionsqlite3connectrjRow row_factoryrJs r rSessionManager.connectionsH    #&t/E/EW[\D +2;;D   (rcbURb"URR5 SUlgg)zClose the sqlite connectionN)rcloserJs r rSessionManager.closes( << # LL   DL $rc$UR5 g)z+Close connection once SessionManager closesN)rrJs r __del__SessionManager.__del__s  rc# SnURRSU45 URR5nUbURUSS9IShvN nUbSnU$N 7f)z2Check to see if the session of a given name existsFz"SELECT * FROM session WHERE path=?NT)tolerate_culled)rrfetchone row_to_model)r,rwrqrowmodels r session_existsSessionManager.session_existssh @4'Jkk""$ ? ++C+FFE  GsAA A A r'c>[[R"55$)zCreate a uuid for a new session)r;uuiduuid4rJs r new_session_idSessionManager.new_session_ids4::<  rrwr5r kernel_namer%c# UR5n[US9nURRU5 UbXPR;aOUR XaX#U5IShvN nXWlURRU5 URXaX#US9IShvN nURRU5 [[[[4U5$NvN>7f)zCreates a session and returns its model Parameters ---------- name: ModelName(str) Usually the model name, like the filename associated with current kernel. r$N)rwr5rr%) rr"r~r9kernel_managerstart_kernel_for_sessionr% save_sessionr`rdictr;r) r,rwr5rrr%r$rFresults r create_sessionSessionManager.create_sessions ((* $ ; %%f-  Y2E2E%E ";;$kI% %%f-(( 9)   %%f-DcNF++  s$AC C!9CC=CCcUb:URRU5n[RR X25n[ U[ 5(de0[RESU0E$)aReturn the environment variables that need to be set in the kernel Parameters ---------- path : str the url path for the given session. name: ModelName(str), optional Here the name is likely to be the name of the associated file with the current kernel at startup time. JPY_SESSION_NAME)r cwd_for_pathosrwjoinr)r;environ)r,rwr5cwds r get_kernel_envSessionManager.get_kernel_env(s\  %%2248C77<<*D$$$$$7"**70$77rr$c# [URRUS95IShvN nURX#5nURR UUUS9IShvN n[ [U5$NHN7f)aStart a new kernel for a given session. Parameters ---------- session_id : str uuid for the session; this method must be given a session_id path : str the path for the given session - seem to be a session id sometime. name : str Usually the model name, like the filename associated with current kernel. type : str the type of the session kernel_name : str the name of the kernel specification to use. The default kernel name will be used if not provided. )rwN)rwrenv)r contents_managerget_kernel_pathrr start_kernelrr;) r,r$rwr5rr kernel_path kernel_envr%s r r'SessionManager.start_kernel_for_session;s|2))>)>)N)NTX)N)YZZ ((4 --::#;  C##[ s!&A5A13A5A3A53A5c~# URRSXX4U45 URUS9IShvN nU$N7f)aCSaves the items for the session with the given session_id Given a session_id (and any other of the arguments), this method creates a row in the sqlite session database that holds the information for a session. Parameters ---------- session_id : str uuid for the session; this method must be given a session_id path : str the path for the given session name : str the name of the session type : str the type of the session kernel_id : str a uuid for the kernel associated with this session Returns ------- model : dict a dictionary of the session model z&INSERT INTO session VALUES (?,?,?,?,?)rN)rr get_session)r,r$rwr5rr%rs r rSessionManager.save_session^sH2  4 t9 5 '':'>> ?s 2=;=c# U(d Sn[U5e/nUH6nX@R;aSU3n[U5eURSU-5 M8 SSRU5-nURR U[ UR555 URR5nUc[/nUR5HupURUSU <35 M [R"SS S RU5-5eURU5IShvN n U $![a SnNf=fN![a)n [R"SS [U 5-5U eSn A ff=f7f) aReturns the model for a particular session. Takes a keyword argument and searches for the value in the session database, then returns the rest of the session's info. Parameters ---------- **kwargs : dict must be given one of the keywords and values from the session database (i.e. session_id, path, name, type, kernel_id) Returns ------- model : dict returns a dictionary that includes all the information from the session described by the kwarg. zmust specify a column to queryzNo such column: %s=?zSELECT * FROM session WHERE %sz AND N=izSession not found: %s, )r3_columnsr\rrrrbvaluesrKeyErroritemsr HTTPErrorrr;) r,rr/ conditionscolumnqueryrqkeyrlres r rSessionManager.get_session~sd$2CC.  F]]*(1n$   fvo .  1GLL4LM E4 #89 ++&&(C ;A$lln C5%+,---%< ! %MN N N++C00E  C 1 N--%> KK (;diioN E#GT&--/%:#GJ#GH 4&& 5 5 KK  NQ[P\ %)KK$8$8$: !D    * *YDWDWX\Dc * d 6 6sD+D(DD+c&# XR;$7f)zQChecks if the kernel is still considered alive and returns true if its not found.)r)r,r%s r kernel_culledSessionManager.kernel_culleds 3 333sc# [URUS55IShvN nU(agURRSUS45 SR USUSS9nU(aUR R US35 g[U5e[URRUS55IShvN nUSUSUS US US .nUS S :XaUSUS S .US 'U$NN37f)z@Takes sqlite database session row and turns it into a dictionaryr%N&DELETE FROM session WHERE session_id=?r$zKernel '{kernel_id}' appears to have been culled or died unexpectedly, invalidating session '{session_id}'. The session has been removed.)r%r$z Continuing...rwr5r)idrwr5rkernelnotebook)rwr5) r rrrformatlogwarningrr kernel_model)r,rrrr/rrs r rSessionManager.row_to_models$01C1CC DT1U$VV  KK   H3|K\J^ _UU[U[!+.3|;LV\V    C5!893- )$*=*=*J*J3{K[*\]] l#KKK"   v;* $),Vc&k JE*  AW*^s"!C6C2BC6C42C64C6c# URRS5n/nUR5H.nURU5IShvN nUR U5 M0 U$N![ a MCf=f7f)zWReturns a list of dictionaries containing all the information from the session databasezSELECT * FROM sessionN)rrfetchallrr\r)r,crrrs r list_sessionsSessionManager.list_sessionsst KK   7 8::>wx?PQU?VWXXX DzmT %%f-@Xs!7B-B)1B-+B+,>B-+B-)rrr~)NNNNN)N)NNNN)F),rrrrrrtagrjrrzrrrrrGrrrpropertyrrrrrr;rrr rrrrrrrrrr>rrrrr __classcell__)rs@r rdrds  O cc!"#(bcN* F @ ; GKBH     !! #$(",0#' ,sm,y!,sm , j) , C= , c3h,D@D8SM8)1))<8 c3h8&!$!$sm!$y! !$ sm !$ j) !$ !$F@1f"eH4S4T4"H ..rrd)&rrrortypingrrrrrr;rr r ImportError pysqlite2r dataclassesr r jupyter_core.utilsr tornador traitletsrrrrtraitlets.config.configurablerjupyter_server.traittypesr Exceptionrr"r@rdrrr rs#  66 \3 ' K % , *+===9)  7F7F 7Ft@)@)Fr.(r.e,+,sB BB