PibdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlmZmZmZmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*m+Z+m,Z,ej-e,dfZ.ej-e,dfZ/ej-e,e+dfZ0ed GddZ1GddZ2GddZ3ed GddZ4GddZ5GddZ6GddZ7GddZ8dS)zRDF4J client module.) annotationsN) dataclass)AnyBinaryIOIterable)BNode) RDF4JUnsupportedProtocolErrorRDFLibParserErrorRepositoryAlreadyExistsErrorRepositoryErrorRepositoryFormatErrorRepositoryNotFoundErrorRepositoryNotHealthyErrorTransactionClosedErrorTransactionCommitErrorTransactionPingErrorTransactionRollbackError)build_context_parambuild_infer_param build_sparql_query_accept_headerbuild_spo_paramrdf_payload_to_streamvalidate_graph_namevalidate_no_bnodes)DATASET_DEFAULT_GRAPH_IDDatasetGraph)Result)IdentifiedNodeLiteralURIRefT)frozenc(eZdZUdZded<ded<dS)NamespaceListingResultz'RDF4J namespace and prefix name result.strprefix namespaceN)__name__ __module__ __qualname____doc____annotations__o/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/rdflib/contrib/rdf4j/client.pyr$r$-s(11KKKNNNNNr.r$cleZdZdZddZedZedZdd Zd Z ddZ ddZ ddZ dS)RDF4JNamespaceManagerzA namespace manager for RDF4J repositories. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. identifierr% http_client httpx.Clientc"||_||_dSN) _identifier _http_clientselfr2r3s r/__init__zRDF4JNamespaceManager.__init__=s%'r.c|jSr6r8r:s r/r3z!RDF4JNamespaceManager.http_clientA   r.c|jSzRepository identifier.r7r>s r/r2z RDF4JNamespaceManager.identifierE r.returnlist[NamespaceListingResult]c0ddi}|jd|jd|}| |}|dd}d|DS#t t f$r}td |d }~wwxYw) zList all namespace declarations in the repository. Returns: list[NamespaceListingResult]: List of namespace and prefix name results. Raises: RepositoryFormatError: If the response format is unrecognized. Acceptapplication/sparql-results+json/repositories/ /namespacesheadersresultsbindingsc`g|]+}t|dd|dd,S)r&valuer')r&r')r$).0rows r/ z.RDF4JNamespaceManager.list..^sR  'x=1!+.w7r.Unrecognised response format: N)r3getr2raise_for_statusjsonKeyError ValueErrorr r:rLresponsedatarMerrs r/listzRDF4JNamespaceManager.listJs 7 #'' 9T_ 9 9 97(   !!### P==??D9oj1G #  *% P P P'(N(N(NOO O Ps-A--B>BBcddi}|jd|jd|}|dS)z3Clear all namespace declarations in the repository.rGrHrIrJrKN)r3deleter2rV)r:rLr[s r/clearzRDF4JNamespaceManager.clearhs\ 7 #** 9T_ 9 9 97+   !!#####r.r& str | Nonec|stdddi} |jd|jd||}||jS#t j$r}|jj dkrYd}~dSd}~wwxYw) zGet the namespace URI for a given prefix. Parameters: prefix: The prefix to lookup. Returns: The namespace URI or `None` if not found. Prefix cannot be empty.rG text/plainrI /namespaces/rKN) rYr3rUr2rVtexthttpxHTTPStatusErrorr[ status_code)r:r&rLr[r]s r/rUzRDF4JNamespaceManager.getrs 8677 7 l  '++FFFfFFPW,H  % % ' ' '= $   |'3..ttttt  sAAB(A?>A??Br'c|std|stdddi}|jd|jd|||}|dS) a!Set the namespace URI for a given prefix. !!! note If the prefix was previously mapped to a different namespace, this will be overwritten. Parameters: prefix: The prefix to set. namespace: The namespace URI to set. rdzNamespace cannot be empty. Content-TypererIrfrLcontentN)rYr3putr2rV)r:r&r'rLr[s r/setzRDF4JNamespaceManager.sets 8677 7 ;9:: : L #'' BT_ B B& B B(   !!#####r.c|std|jd|jd|}|dS)z|Remove the namespace declaration for a given prefix. Parameters: prefix: The prefix to remove. rdrIrfN)rYr3r`r2rV)r:r&r[s r/removezRDF4JNamespaceManager.removesb  8677 7#** BT_ B B& B B   !!#####r.Nr2r%r3r4)rDrE)r&r%rDrb)r&r%r'r%)r&r%) r(r)r*r+r;propertyr3r2r^rarUrqrsr-r.r/r1r15s((((!!X!  X PPPP<$$$2$$$$2 $ $ $ $ $ $r.r1ceZdZdZddZedZedZedd Z dd Z ddZ ddZ ddZ ddZdS)GraphStoreManagerzAn RDF4J Graph Store Protocol Client. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. r2r%r3r4c0||_||_d|_dS)Napplication/n-triples)r7r8 _content_typer9s r/r;zGraphStoreManager.__init__s %'4r.c|jSr6r=r>s r/r3zGraphStoreManager.http_clientr?r.c|jSrArBr>s r/r2zGraphStoreManager.identifierrCr. graph_name URIRef | strci}t|tr |tks-t|tr|ttkrnt||d<|S)Ngraph) isinstancer!rr%)r}paramss r/_build_graph_name_paramsz*GraphStoreManager._build_graph_name_paramssd z6 * * .666*c**7c":;;;; !*ooF7O r.cfd|jd}t|tr|tkr|dz }|S)NrIz/rdf-graphs/servicez?default)r2rr!r)r:r}urls r/ _build_urlzGraphStoreManager._build_urls@CtCCC j& ) ) j>$$$$$$r.rwcJeZdZUdZded<ded<ded<ded<dZd ed <dS) RepositoryListingResulta'RDF4J repository listing result. Parameters: identifier: Repository identifier. uri: Repository URI. readable: Whether the repository is readable by the client. writable: Whether the repository is writable by the client. title: Repository title. r%r2uriboolreadablewritableNrbtitle)r(r)r*r+r,rr-r.r/rrRsSOOO HHHNNNNNNEr.rceZdZdZd0dZedZedZed1d Zed2d Z d3dZ d4d5dZ e d6dZ d7dZd7dZd8dZ d9d:d'Z d;dd,Z d?d@d.Zejd/ZdS)A RepositoryzRDF4J repository client. Parameters: identifier: The identifier of the repository. http_client: The httpx.Client instance. r2r%r3r4c>||_||_d|_d|_dSr6)r7r8_namespace_manager_graph_store_managerr9s r/r;zRepository.__init__ms(%'@D>B!!!r.c|jSr6r=r>s r/r3zRepository.http_clientsr?r.c|jSrArBr>s r/r2zRepository.identifierwrCr.rDr1c\|jt|j|j|_|jS)z%Namespace manager for the repository.)rr1r2r3r>s r/ namespaceszRepository.namespaces|s4  " *&;!1''D #&&r.rwc\|jt|j|j|_|jS)z'Graph store manager for the repository.)rrwr2r3r>s r/graphszRepository.graphss4  $ ,(9!1))D %((r.rc dddd} |jd|j|d}|dS#tj$r^}|jjdkrtd |jd td |jd |jjd |jj d }~wwxYw)a%Repository health check. Returns: bool: True if the repository is healthy, otherwise an error is raised. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryNotHealthyError: If the repository is not healthy. application/sparql-queryrH)rmrGrIzASK {}rnTrg Repository not found.z is not healthy.  - N) r3rr7rVrirjr[rkrrrh)r:rLr[r]s r/healthzRepository.healths77   ',,3!133Wh-H  % % ' ' '4$   |'3..-?$"2???,qd.qqAYqq^a^j^oqq   s9AB/AB**B/Nr}&URIRef | Iterable[URIRef] | str | Noneintct|i}t|||jd|jd|}|||jS)The number of statements in the repository or in the specified graph name. Parameters: graph_name: Graph name(s) to restrict to. The default value `None` queries all graphs. To query just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. Returns: The number of statements. Raises: RepositoryFormatError: Fails to parse the repository size. rIz/sizer)rrr3rUr2rV_to_sizerhrs r/sizezRepository.sizes~" J'''!#FJ///#'' 3T_ 3 3 3F(   !!###}}X]+++r.rc t|}|dkr|Std|#t$r}td||d}~wwxYw)NrzInvalid repository size: z!Failed to parse repository size: )rrYr )rrPr]s r/rzRepository._to_sizesv IIEzz @@@AA A   '9C99  s++ A AA queryc ddi}t|||s&|jd|j||}n)|jd|j|d|i|}| t jtj |j |j d dd S#t$r3}td |j dd ||d }~wwxYw) aExecute a SPARQL query against the repository. !!! note A POST request is used by default. If any keyword arguments are provided, a GET request is used instead, and the arguments are passed as query parameters. Parameters: query: The SPARQL query to execute. **kwargs: Additional keyword arguments to include as query parameters in the request. See [RDF4J REST API - Execute SPARQL query](https://rdf4j.org/documentation/reference/rest-api/#tag/SPARQL/paths/~1repositories~1%7BrepositoryID%7D/get) for the list of supported query parameters. rmrrIrnrr;r content_type$Failed to parse SPARQL query result : N)rr3rr2rUrVrrioBytesIOrorLsplitrXr )r:rkwargsrLr[r]s r/rzRepository.querysN"#=>(888 ',,222GU-HH'++2221&1,H !!### < 8+,,%-n=CCCHHK    #dx7G7K7KN7[7[dd_bdd  s;AC D .DD cddi}|jd|jd||}|dS)zExecute a SPARQL update operation on the repository. Parameters: query: The SPARQL update query to execute. rmzapplication/sparql-updaterI /statementsrnN)r3rr2rV)r:rrLr[s r/updatezRepository.updates\ "#>?#(( 9T_ 9 9 9)   !!#####r.list[IdentifiedNode]cddi}|jd|jd|}| g}|ddD]}|dd }|dd }|d kr#|t |G|d kr#|t|ptd ||S#t$r}td||d}~wwxYw)zGet a list of all graph names in the repository. Returns: A list of graph names. Raises: RepositoryFormatError: Fails to parse the repository graph names. rGrHrIz /contextsrKrMrN contextIDrPtyperbnodezInvalid graph name type: z(Failed to parse repository graph names: N) r3rUr2rVrWappendr!rrY Exceptionr )r:rLr[valuesrRrP value_typer]s r/ graph_nameszRepository.graph_namessH 7 #'' 7T_ 7 7 7(   !!### +-F}}y1*= O OK(1 -f5 &&MM&--00007**MM%,,////$%M%M%MNNNM   '@3@@  sB%C%% D/DDTsubj SubjectTypepred PredicateTypeobj ObjectTypeinferrrbGraph | Datasetct|||||d}d|i}i}t||t||||t|||jd|jd||} | gd} || vr)t | j | } n(t | j | } |j D]$} | | j| jd %| S#t"$r} t%d | | d} ~ wwxYw) Get RDF statements from the repository matching the filtering parameters. !!! Note The terms for `subj`, `pred`, `obj` or `graph_name` cannot be [`BNodes`][rdflib.term.BNode]. Parameters: subj: Subject of the statement to filter by, or `None` to match all. pred: Predicate of the statement to filter by, or `None` to match all. obj: Object of the statement to filter by, or `None` to match all. graph_name: Graph name(s) to restrict to. The default value `None` queries all graphs. To query just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. infer: Specifies whether inferred statements should be included in the result. content_type: The content type of the response. A triple-based format returns a [Graph][rdflib.graph.Graph], while a quad-based format returns a [`Dataset`][rdflib.graph.Dataset]. Returns: A [`Graph`][rdflib.graph.Graph] or [`Dataset`][rdflib.graph.Dataset] object with the repository namespace prefixes bound to it. Napplication/n-quadsrGrrIrrry text/turtlezapplication/rdf+xmlrTreplaceError parsing RDF: )rrrrr3rUr2rVrrrhrrr^bindr&r'rr r:rrrr}rrrLrr[triple_formatsretvalresultr]s r/rUzRepository.get&sH 4sJ777  0L\*!#FJ///dC000&....#'' 9T_ 9 9 9(   !!###    J~--HM,OO hmLQQ/..00 K K FM6+;T JJJJM J J J#$?#$?$?@@c I JsBD$$ E.EEr\(str | bytes | BinaryIO | Graph | Datasetbase_uric(t|\}} d|pdi}i}|||d<|jd|jd|||}||r|dSdS#|r|wwxYw)TUpload and append statements to the repository. Parameters: data: The RDF data to upload. base_uri: The base URI to resolve against for any relative URIs in the data. content_type: The content type of the data. Defaults to `application/n-quads` when the value is `None`. rmrNbaseURIrIrr)rr3rr2rVr r:r\rrrrrLrr[s r/uploadzRepository.uploadis 5T::  %|'L7LMGF#$,y!',,==== -H  % % ' ' '    |   s A A88Bcft|\}}t| d|pdi}i}t|||||d<|jd|jd|||} | |r|dSdS#|r|wwxYw)a]Upload and overwrite statements in the repository. Parameters: data: The RDF data to upload. graph_name: Graph name(s) to restrict to. The default value `None` applies to all graphs. To apply to just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. base_uri: The base URI to resolve against for any relative URIs in the data. content_type: The content type of the data. Defaults to `application/n-quads` when the value is `None`. rmrNrrIrr)rrrr3rpr2rVr) r:r\r}rrrrrLrr[s r/rzRepository.overwrites, 5T:: J''' %|'L7LMG%'F  3 3 3#$,y!'++==== ,H  % % ' ' '    |   s ABB0Nonect||||i}t||t|||||jd|jd|}|dS)aDeletes statements from the repository matching the filtering parameters. !!! Note The terms for `subj`, `pred`, `obj` or `graph_name` cannot be [`BNodes`][rdflib.term.BNode]. Parameters: subj: Subject of the statement to filter by, or `None` to match all. pred: Predicate of the statement to filter by, or `None` to match all. obj: Object of the statement to filter by, or `None` to match all. graph_name: Graph name(s) to restrict to. The default value `None` queries all graphs. To query just the default graph, use [`DATASET_DEFAULT_GRAPH_ID`][rdflib.graph.DATASET_DEFAULT_GRAPH_ID]. rIrrN)rrrr3r`r2rV)r:rrrr}rr[s r/r`zRepository.deletes0 4sJ777!#FJ///dC000#** 9T_ 9 9 9+   !!#####r.c#bKt|5}|VddddS#1swxYwYdS)z,Create a new transaction for the repository.N) Transaction)r:txns r/ transactionzRepository.transactions   #III                  s $((rt)rDr1)rDrwrDrr6)r}rrDr)rr%rr%)rDrNNNNTNrrrrrrr}rrrrrbrDrNNr\rrrbrrb)NNN)r\rr}rrrbrrb)NNNN) rrrrrrr}rrDr)r(r)r*r+r;rur3r2rrrrrrrrrrUrrr` contextlibcontextmanagerrr-r.r/rresCCCC !!X!  X '''X')))X):,,,,,4   \ $$$$L $ $ $ $F!"=A#'AJAJAJAJAJL $#' D>B##' '''''V!"=A !$!$!$!$!$Fr.rceZdZdZd-dZdZdZedZedZ ed.d Z d Z d/dZ dZ dZdZdZdZd0d1dZd2dZd2dZ d3d4d Z d5d6d*Z d3d7d,ZdS)8rzRAn RDF4J transaction. Parameters: repo: The repository instance. reporc"||_d|_dSr6)_repo_url)r:rs r/r;zTransaction.__init__s $ r.c8||_|Sr6_start_transactionrr>s r/ __enter__zTransaction.__enter__s++--  r.c|js=||n& |n#t$rYnwxYwdS)NF) is_closedcommitrollbackrr:exc_typeexc_valexc_tbs r/__exit__zTransaction.__exit__s\~  MMOOOO Dus5 AAc|jS)zThe repository instance.)rr>s r/rzTransaction.repos zr.c|jS)zThe transaction URL.rr>s r/rzTransaction.urls yr.rDrc|jduS)z"Whether the transaction is closed.Nrr>s r/r zTransaction.is_closedsyD  r.c2|jrtddS)Nz The transaction has been closed.)r rr>s r/_raise_for_closedzTransaction._raise_for_closeds( > M()KLL L M Mr.r%c|jjd|jjd}||jdS)NrIz /transactionsLocation)rr3rr2rVrLr:r[s r/rzTransaction._start_transaction sQ9(-- @TY1 @ @ @   !!### ++r.cd|_dSr6rr>s r/_close_transactionzTransaction._close_transactions  r.c8||_dS)zOpens a transaction.Nrr>s r/openzTransaction.opens++-- r.c|ddi}|jj|j|}|jdkrt d|jd|j|dS)zCommit the transaction. Raises: TransactionCommitError: If the transaction commit fails. TransactionClosedError: If the transaction is closed. actionCOMMITrzTransaction commit failed: rN) rrr3rprrkrrhrr:rr[s r/r zTransaction.commits    H%9(,,TXf,EE  3 & &(Vh.BVVx}VV  !!!!!r.c|jj|j}|jdkrt d|jd|j|dS)zRoll back the transaction.zTransaction rollback failed: rN)rr3r`rrkrrhrrs r/r zTransaction.rollback(sn9(//99  3 & &*X0DXXXX  !!!!!r.c|ddi}|jj|j|}|jdkrt d|jd|jdS)zPing the transaction. Raises: RepositoryTransactionPingError: If the transaction ping fails. TransactionClosedError: If the transaction is closed. r PINGrr"zTransaction ping failed: rN)rrr3rprrkrrhr#s r/pingzTransaction.ping1s    F#9(,,TXf,EE  3 & &&TH,@TTX]TT  ' &r.Nr}rc"|t|ddi}t|||jj|j|}||j|j S)rr SIZEr) rrrrr3rprrVrrhrs r/rzTransaction.size@s"    J'''F#FJ///9(,,TXf,EE!!###y!!(-000r.rc i}t||d|d}|jj|j|i||}| t jtj |j |j d ddS#t$r3}td|j dd ||d }~wwxYw) aExecute a SPARQL query against the repository. Parameters: query: The SPARQL query to execute. **kwargs: Additional keyword arguments to include as query parameters in the request. See [RDF4J REST API - Execute SPARQL query](https://rdf4j.org/documentation/reference/rest-api/#tag/SPARQL/paths/~1repositories~1%7BrepositoryID%7D/get) for the list of supported query parameters. QUERY)r rrrmrrrrrN)rrr3rprrVrrrrrorLrrXr rU)r:rrrLrr[r]s r/rzTransaction.queryYs#%(888#e449(,, Hg.B.B6.B-   !!### < 8+,,%-n=CCCHHK    #dx7G7K7KN7[7[dd_bdd  sAB)) C&3.C!!C&c d|d}|jj|ji||}|dS)aExecute a SPARQL update operation on the repository. Parameters: query: The SPARQL update query to execute. **kwargs: Additional keyword arguments to include as query parameters See [RDF4J REST API - Execute a transaction action](https://rdf4j.org/documentation/reference/rest-api/#tag/Transactions/paths/~1repositories~1%7BrepositoryID%7D~1transactions~1%7BtransactionID%7D/put) for the list of supported query parameters. UPDATE)r rrN)rr3rprrV)r:rrrr[s r/rzTransaction.updatets\%669(,, H'f''-   !!#####r.r\rrrbrc.t|\}}d|pdi}ddi}|||d< |jj|j|||}||r|dSdS#|r|wwxYw)rrmrr ADDNrrrrr3rprrVrrs r/rzTransaction.uploads 5T:: !<#H3HIE"   (F9  y,00 1H  % % ' ' '    |    s r/r3zRepositoryManager.http_clientr?r.rDlist[RepositoryListingResult]cddi}|jd|}| |}|dd}d|DS#tt f$r}t d|d }~wwxYw) zList all available repositories. Returns: list[RepositoryListingResult]: List of repository results. Raises: RepositoryFormatError: If the response format is unrecognized. rGrHz /repositoriesrKrMrNc g|]m}t|dd|dd|dd|dd|didnS)idrPrrrr)r2rrrr)rrU)rQrs r/rSz*RepositoryManager.list...s   (#Dz'2U G,!*-g6!*-g6((7B//33G<<    r.rTN)r3rUrVrWrXrYr rZs r/r^zRepositoryManager.lists 7 #'''II!!### P==??D9oj1G  $    *% P P P'(N(N(NOO O Ps-A$$B 5BB  repository_idr%rcXt||j}||S)aGet a repository by ID. !!! Note This performs a health check before returning the repository object. Parameters: repository_id: The identifier of the repository. Returns: Repository: The repository instance. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryNotHealthyError: If the repository is not healthy. )rr3r)r:r?rs r/rUzRepositoryManager.get;s( -)9::  r.rr\rc d|i}|jd|||}|||S#tj$r)}|jjdkrtd|dd}~wwxYw)aCreate a new repository. Parameters: repository_id: The identifier of the repository. data: The repository configuration in RDF. content_type: The repository configuration content type. Raises: RepositoryAlreadyExistsError: If the repository already exists. RepositoryNotHealthyError: If the repository is not healthy. rmrIrnirz already exists.N) r3rprVrUrirjr[rkr )r:r?r\rrLr[r]s r/createzRepositoryManager.createOs %|4G'++000'4,H  % % ' ' '88M** *$   |'3..2A-AAA   sA AB$BBrc ^ |jd|}||jdkr4t d|d|jd|jd S#tj$r)}|j jdkrtd|dd }~wwxYw) aDelete a repository. Parameters: repository_id: The identifier of the repository. Raises: RepositoryNotFoundError: If the repository is not found. RepositoryError: If the repository is not deleted successfully. rIr%z9Unexpected response status code when deleting repository rrrgrrN) r3r`rVrkr rhstriprirjr[r)r:r?r[r]s r/r`zRepositoryManager.deleteks '../O /O/OPPH  % % ' ' '#s**%RP]RRaiauRR{C{H{N{N{P{PRR+*$   |'3..-.VM.V.V.VWWW  sA0A44B,$B''B,N)r3r4)rDr;)r?r%rDr)r)r?r%r\r%rr%rDr)r?r%rDr) r(r)r*r+r;rur3r^rUrBr`r-r.r/r8r8s ((((!!X!PPPP>*BO8r.r8cxeZdZdZ ddd Zd ZdZedZeddZ eddZ dZ dS) RDF4JClientaRDF4J client. Parameters: base_url: The base URL of the RDF4J server. auth: Authentication tuple (username, password). timeout: Request timeout in seconds (default: 30.0). kwargs: Additional keyword arguments to pass to the httpx.Client. N>@base_urlr%authtuple[str, str] | Nonetimeoutfloatrrc d|ds|dz }tjd|||d||_d|_ |j}n>#tj$r,}|td||d}~wwxYw|dkr'|td|ddS)N/)rHrIrKz"Failed to check protocol version: zRDF4J server protocol version z2 is not supported. Minimum required version is 12.r-) endswithriClientr8_repository_managerprotocol RequestErrorrr )r:rHrIrKrprotocol_versionr]s r/r;zRDF4JClient.__init__s  %%  OH!L D'  =C  >B  #}  !    JJLLL/:S::   b JJLLL/u1Auuu  ! sAB'A;;Bc|Sr6r-r>s r/rzRDF4JClient.__enter__s r.c.|dSr6)rr s r/rzRDF4JClient.__exit__s r.c|jSr6r=r>s r/r3zRDF4JClient.http_clientr?r.rDr8cP|jt|j|_|jS)z.Server-level repository management operations.)rRr8r3r>s r/ repositorieszRDF4JClient.repositoriess)  # +'89I'J'JD $''r.c|jdddi}|t|jS)zhThe RDF4J REST API protocol version. Returns: The protocol version number. z /protocolrGrerK)r3rUrVrLrhrDrs r/rSzRDF4JClient.protocolsR#'' h =U'VV!!###X]((**+++r.c8|jdS)z"Close the underlying httpx.Client.N)r3rr>s r/rzRDF4JClient.closes      r.)NrG)rHr%rIrJrKrLrr)rDr8)rDrL) r(r)r*r+r;rrrur3rZrSrr-r.r/rFrFs(, 4!!X!(((X( ,,,X,!!!!!r.rF)9r+ __future__rrrtypingt dataclassesrrrrrirdflibrrdflib.contrib.rdf4j.exceptionsr r r r r rrrrrrrdflib.contrib.rdf4j.utilrrrrrrr rdflib.graphrrr rdflib.queryr rdflib.termrr r!Unionrrrr$r1rwrrrr8rFr-r.r/rhs"""""" !!!!!!**********                           BAAAAAAAAA7777777777gfdl#  % WVWd* +  $z$z$z$z$z$z$z$z$z]$]$]$]$]$]$]$]$@ $$ssssssssl ppppppppf qqqqqqqqhB!B!B!B!B!B!B!B!B!B!r.