+ nDj5^RIHt^RIt^RIHt^RIHt^RIHt^RI H t H t ^RI H t ^RIHt^R IHt]'d ^R IHt^R IHtR .t!R R 4tR#)) annotationsN)PathLike)Path) TYPE_CHECKING)Self deprecated)_send_warning_or_raise)_ServerInternal) CatalogClient)Sequence) TracebackTypeServerc ]tRt^tRtRRRRRRRRRR/R R lltR R lt]!R 4RRl4tRRlt RRlt RRlt RRlt RRlt RRltRRltRRltR tR#)!ra A Rerun server instance. This class allows you to start and manage a Rerun server programmatically. The server hosts recordings and serves them via HTTP, and provides access to the catalog through a client connection. When the object goes out of scope the server is automatically shut down. The server can be used as a context manager, which will automatically shut down the server when exiting the context. Example ------- ```python import rerun as rr # Start a server with some datasets with rr.server.Server(port=9876, datasets={"my_data": ["path/to/data.rrd"]}) as server: client = server.client() # Use the client to interact with the catalog dataset = client.get_dataset("my_data") ``` host0.0.0.0portNdatasetstablesaddrc 0V^8dQhRRRRRRRRR RR R /#) rstrrz int | NonerzEdict[str, str | PathLike[str] | Sequence[str | PathLike[str]]] | Nonerzdict[str, PathLike[str]] | NonerreturnNone)formats"P/data/cameron/venvs/s3viz/lib/python3.14/site-packages/rerun_sdk/rerun/server.py __annotate__Server.__annotate__1sQM M M  M X M 0 M M  M c VR8XdVR8wdTp\R^\R7Vfn\P!\P\P4;_uu_4pVP R 4VP 4^,pRRR4MTp/p/p VEeVP4Fwr\V \\,4'dQ\V 4p V P4'g\RV RV R24h\V P44W&KvV U u.uFp \V 4NK p p V F+p V P4'dK\RV RV R 24h V U u.uFp \V P44NK up W&K \!TXTT T;'g/P4U U u/uFwrV \V 4bK up p R 7VnR# +'giELg;iuup iuup iuup p i) aJ Create a new Rerun server instance and start it. The server will host recordings and serve them via HTTP. If datasets are provided, they will be loaded and made available when the server starts. Parameters ---------- host: The IP address to bind the server to. port: The port to bind the server to, or `None` to select a random available port. datasets: Optional dictionary specifying dataset to load in the server at startup. Values in the dictionary may be either of: - a single path: must be a directory, all the RRDs it contains will be registered - a sequence of paths: each path must be a RRD file, which will all be registered tables: Optional dictionary mapping table names to lance file paths which will be loaded and made available when the server starts. addr: Deprecated: Renamed to `host` rzQThe `addr` parameter is deprecated in Rerun 0.29, and has been renamed to `host`.)depth_to_user_code warning_typeNz Prefix path 'z' for dataset 'z' must be a directory.zPath 'z' must be a RRD file.)rrrdataset_prefixesr)r)r DeprecationWarningsocketAF_INET SOCK_STREAMbind getsocknameitems isinstancerrris_dir ValueErrorabsoluteis_filer _internal)selfrrrrrs resolved_port all_datasetsall_dataset_prefixesnamepathppathss&$$$$$ r__init__Server.__init__1sD 9 !2D "c#$/  <v~~v/A/ABBaw !  2 CB!M !  &nn. dC(N33:D;;==(=odVSi)jkk14T]]_1E(..23dT!WdE3" yy{{",vaSvMb-c"dd#FK)KU#ajjl*;U)KL&/ )!17=||6J6J6LM6L D#d)O6LM  5CBB&4 *LNs")G,)H4"HH , G= cV^8dQhRR/#rrrr)rs"rrrs$$S$r c 6VPP4#)z7Get the URL of the server to which clients can connect.)r2urlr3s&rrA Server.urls~~!!##r zRenamed to `url`.cV^8dQhRR/#r?r)rs"rrrsr c "VP4#)N)rArBs&raddressServer.addresssxxzr cV^8dQhRR/#r?r)rs"rrrs%%c%r c 6VPP4#)z1Get the host (IP) that we've bound the server to.)r2rrBs&rr Server.hosts~~""$$r cV^8dQhRR/#)rrr r)rs"rrrs?? ?r c VPP4'g \R4h\VPP 4RR7#)a Get a CatalogClient connected to this server. The client can be used to interact with the server's catalog, including querying datasets and tables. Note: the `datafusion` package is required to use the client. The client initialization will fail with an error if the package is not installed. Returns ------- CatalogClient A client for interacting with the server's catalog. Raises ------ RuntimeError If the server is not running. z,Cannot create client: server is not running.N)token)r2 is_running RuntimeErrorr rArBs&rclient Server.clients=*~~((**MN NT^^//1>>r cV^8dQhRR/#)rrboolr)rs"rrrs + +D +r c 6VPP4#)zz Check if the server is currently running. Returns ------- bool `True` if the server is running, `False` otherwise. )r2rNrBs&rrNServer.is_runnings~~((**r cV^8dQhRR/#)rrrr)rs"rrrs " "$ "r c :VPP4R#)z Stop the server. After calling this method, the server will no longer be accessible. Raises ------ RuntimeError If the server is not running. Nr2shutdownrBs&rrYServer.shutdowns !r c V^8dQhRRRR/#rmethodrrrr)rs"rrrs,,C,D,r c <VPPV4R#)zKTesting utility: make the given gRPC method fail with a ``NotFound`` error.N)r2 inject_errorr3r]s&&r _inject_errorServer._inject_errors ##F+r c V^8dQhRRRR/#r\r)rs"rrrs44C4D4r c <VPPV4R#)z=Testing utility: stop failing a previously injected endpoint.N)r2clear_injected_errorr`s&&r_clear_injected_errorServer._clear_injected_errors ++F3r cV^8dQhRR/#)rrrr)rs"rrrs4r c V#)z9Enter the context manager, returning the server instance.rrBs&r __enter__Server.__enter__s r c(V^8dQhRRRRRRRR/#) rexc_typeztype[BaseException] | None exc_valuezBaseException | None tracebackzTracebackType | Nonerrr)rs"rrrs,""2"?S"`t" "r c :VPP4R#)z3Exit the context manager, shutting down the server.NrX)r3rmrnros&&&&r__exit__Server.__exit__s !r )r2)__name__ __module__ __qualname____firstlineno____doc__r<rArrFrrPrNrYrarfrjrq__static_attributes__rr rrrs4M M  M [_ M 37 M M ^$#$%%?4 + ",4""r ) __future__rr'osrpathlibrtypingrtyping_extensionsrrrerun.error_utilsr rerun_bindingsr catalogr collections.abcr typesr __all__rrr rrs<"  .4*"(# *z"z"r