Cj{SSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r J r SSK J r J r JrJrJrJrJrJrJrJrJrJrJr SSKrSSKJr SSKJrJrJrJ r J!r!J"r" SS K#J$r$J%r% SS K&J'r' SS K(J)r)J*r* SS K+J,r, SS K-J.r. SSK/J0r0J1r1 SSK/J2r3 SSK4J5r5 \Rl"\75r8"SS5r9"SS5r:"SS5r;\"S\S\ 4S9r<\\g)N)Future)Queue)EventThread) AnyAsyncGeneratorCallableDict GeneratorListLiteralOptionalTupleTypeVarUnioncastoverload) fail_after)ExecutionResult GraphQLSchemaIntrospectionQuerybuild_ast_schemaparsevalidate)GraphQLRequestsupport_deprecated_request)AsyncTransport)TransportConnectionFailedTransportQueryError)LocalSchemaTransport) Transport)build_client_schemaget_introspection_query_ast) parse_result)str_first_elementct \rSrSrSrSSSSSSSSSSS. S\\\\4S \\ S \\\ \ 4S \ S \\ S \\\\4S\ S\ S\S\4Sjjr\S\ 4Sj5rS\SS4SjrS\SS4Sjr\S\R24Sj5r\SSSS.S\S\\ S\\ S\SS\S\ \\44 Sjj5r\SSS .S\S\\ S\\ S\S!S\S\4 S"jj5r\SSS .S\S\\ S\\ S\ S\S\\ \\4\44 S#jj5rSSSS.S\S\\ S\\ S\ S\S\\ \\4\44 S$jjr\SSSS.S%\\S\\ S\\ S\SS\S\\ \\44 S&jj5r \SSS .S%\\S\\ S\\ S\S!S\S\\4 S'jj5r \SSS .S%\\S\\ S\\ S\ S\S\\\ \\4\\44 S(jj5r SSSS.S%\\S\\ S\\ S\ S\S\\\ \\4\\44 S)jjr \SSSS.S\S\\ S\\ S\SS\S\ \\44 S*jj5r!\SSS .S\S\\ S\\ S\S!S\S\4 S+jj5r!\SSS .S\S\\ S\\ S\ S\S\\ \\4\44 S,jj5r!SSSS.S\S\\ S\\ S\ S\S\\ \\4\44 S-jjr!\SSSS.S%\\S\\ S\\ S\SS\S\\ \\44 S.jj5r"\SSS .S%\\S\\ S\\ S\S!S\S\\4 S/jj5r"\SSS .S%\\S\\ S\\ S\ S\S\\\ \\4\\44 S0jj5r"SSSS.S%\\S\\ S\\ S\ S\S\\\ \\4\\44 S1jjr"\SSSS.S\S\\ S\\ S\SS\S\ \\44 S2jj5r#\SSS .S\S\\ S\\ S\S!S\S\4 S3jj5r#\SSS .S\S\\ S\\ S\ S\S\\ \\4\44 S4jj5r#SSSS.S\S\\ S\\ S\ S\S\\ \\4\44 S5jjr#\SSSS.S%\\S\\ S\\ S\SS\S\\ \\44 S6jj5r$\SSS .S%\\S\\ S\\ S\S!S\S\\4 S7jj5r$\SSS .S%\\S\\ S\\ S\ S\S\\\ \\4\\44 S8jj5r$SSSS.S%\\S\\ S\\ S\ S\S\\\ \\4\\44 S9jjr$\SSSS.S\S\\ S\\ S\SS\S\%\ \\4S44 S:jj5r&\SSS .S\S\\ S\\ S\S!S\S\%\S44 S;jj5r&\SSS .S\S\\ S\\ S\ S\S\\%\ \\4S4\%\S444 S<jj5r&SSSS.S\S\\ S\\ S\ S\S\\%\ \\4S4\%\S444 S=jjr&\SSSS.S\S\\ S\\ S\SS\S\'\ \\4SS44 S>jj5r(\SSS .S\S\\ S\\ S\S!S\S\'\SS44 S?jj5r(\SSS .S\S\\ S\\ S\ S\S\\'\ \\4SS4\'\SS444 S@jj5r(SSSS.S\S\\ S\\ S\ S\S\\'\ \\4SS4\'\SS444 SAjjr(SKSBjr)SCr*SDr+SEr,SFr-SGr.SHr/SIr0SJr1g)LClient/aThe Client class is the main entrypoint to execute GraphQL requests on a GQL transport. It can take sync or async transports as argument and can either execute and subscribe to requests itself with the :func:`execute ` and :func:`subscribe ` methods OR can be used to get a sync or async session depending on the transport type. To connect to an :ref:`async transport ` and get an :class:`async session `, use :code:`async with client as session:` To connect to a :ref:`sync transport ` and get a :class:`sync session `, use :code:`with client as session:` NF r) schema introspection transportfetch_schema_from_transportintrospection_argsexecute_timeoutserialize_variables parse_resultsbatch_interval batch_maxr+r,r-r.r/r0r1r2r3r4c U(aU(aS5e[U5n[U[5(a[U5n [ U 5nU(a5U(a.U(aS5e[ U5R S:XaS5eU(aU(d [U5nXlX l UcS5eX0l X@l Uc0OUUl X`l XplXlXlXlg)aInitialize the client with the given parameters. :param schema: an optional GraphQL Schema for local validation See :ref:`schema_validation` :param transport: The provided :ref:`transport `. :param fetch_schema_from_transport: Boolean to indicate that if we want to fetch the schema from the transport using an introspection query. :param introspection_args: arguments passed to the :meth:`gql.utilities.get_introspection_query_ast` method. :param execute_timeout: The maximum time in seconds for the execution of a request before a TimeoutError is raised. Only used for async transports. Passing None results in waiting forever for a response. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. Default: False. :param parse_results: Whether gql will try to parse the serialized output sent by the backend. Can be used to deserialize custom scalars or enums. :param batch_interval: Time to wait in seconds for batching requests together. Batching is disabled (by default) if 0. :param batch_max: Maximum number of requests in a single batch. z9Cannot provide introspection and schema at the same time.z>Cannot fetch the schema from transport if is already provided.AppSyncWebsocketsTransportzfetch_schema_from_transport=True is not allowed for AppSyncWebsocketsTransport because only subscriptions are allowed on the realtime endpoint.NzAYou need to provide either a transport or a schema to the Client.)r# isinstancestrrrtype__name__r!r+r,r-r.r/r0r1r2r3r4) selfr+r,r-r.r/r0r1r2r3r4 type_def_asts \/home/rurouni/.local/share/pipx/venvs/strix-agent/lib/python3.13/site-packages/gql/client.py__init__Client.__init__CsF  KJ K(7F fc " " =L%l3F 4 PO PI//3OO S O ),V4I06 Ar@c jUnUR"U4UUUS.UD6sSSS5 $!,(df  g=frs execute_batchr;ryr1r%rdrerws r=r|r}!s<W(($7)%9   TTrxc # g7frgrhris r= execute_asyncClient.execute_async4 c # g7frgrhris r=rr? rc # g7frgrhris r=rrJ 25rc# UIShvN nUR"U4UUUS.UD6IShvN sSSS5IShvN $N4NN !,IShvN (df  g=f7frHNrcrtrvs r=rrUsS47 $7)%9   44444PA>AAAA AAAAAA A AAc # g7frgrhr{s r=execute_batch_asyncClient.execute_batch_asynch  #rc # g7frgrhr{s r=rrs !$rc # g7frgrhr{s r=rr~ >Arc# UIShvN nUR"U4UUUS.UD6IShvN sSSS5IShvN $N4NN !,IShvN (df  g=f7frrrs r=rrsU47 ..$7)%9   44444rc grgrhris r=ruClient.executerlr@c grgrhris r=rurror@c grgrhris r=rurrqr@c [UR[5(aTUR5nUR 5(aS5eUR UR "U4UUUS.UD65nU$UR"U4UUUS.UD6$)aExecute the provided request against the remote server using the transport provided during init. This function **WILL BLOCK** until the result is received from the server. Either the transport is sync and we execute the query synchronously directly OR the transport is async and we execute the query in the asyncio loop (blocking here until answer). This method will: - connect using the transport to get a session - execute the GraphQL request on the transport session - close the session and close the connection to the server If you have multiple requests to send, it is better to get your own session and execute the requests in your session. The extra arguments passed in the method will be passed to the transport execute method. zpCannot run client.execute(query) if an asyncio loop is running. Use 'await client.execute_async(query)' instead.rc)r7r-rra is_runningrun_until_completerrj)r;rFr1r%rdrer`rPs r=rurs> dnnn 5 5'')D(( D ( **""(;!-)=   DK$$$7)%9    r@c grgrhr{s r=rClient.execute_batchr~r@c grgrhr{s r=rrrr@c grgrhr{s r=rrrr@c [UR[5(aTUR5nUR 5(aS5eUR UR "U4UUUS.UD65nU$UR"U4UUUS.UD6$)aExecute multiple GraphQL requests in a batch against the remote server using the transport provided during init. This function **WILL BLOCK** until the result is received from the server. Either the transport is sync and we execute the query synchronously directly OR the transport is async and we execute the query in the asyncio loop (blocking here until answer). This method will: - connect using the transport to get a session - execute the GraphQL requests on the transport session - close the session and close the connection to the server If you want to perform multiple executions, it is better to use the context manager to keep a session active. The extra arguments passed in the method will be passed to the transport execute method. zvCannot run client.execute_batch(query) if an asyncio loop is running. Use 'await client.execute_batch(query)' instead.rc)r7r-rrarrrr|)r;ryr1r%rdrer`rPs r=rrs> dnnn 5 5'')D(( D ( **(((;!-)=   DK**$7)%9    r@c grgrhris r=subscribe_asyncClient.subscribe_asyncV03r@c grgrhris r=rra14r@c grgrhris r=rrl r@c # UIShvN nUR"U4UUUS.UD6nUShvN nU7v MN-N SSS5IShvN g!,IShvN (df  g=f7fr) subscribe) r;rFr1r%rdrerw generatorresults r=rryse47))$7)%9   I!* f   44444s[A(7A(A;9;AA(;A A(A A(A%A  A%!A(c grgrhris r=rClient.subscriberr@c grgrhris r=rrrqr@c grgrhris r=rrrr@c+# UR5nUR5(aS5eUR"U4UUUS.UD6n[R"UR 5US9nUR U5n U v M:![a g[[[4aT [R"UR5US9 WR5 UR UR55 ef=f7f)zlExecute a GraphQL subscription with a python generator. We need an async transport for this functionality. ztCannot run client.subscribe(query) if an asyncio loop is running. Use 'await client.subscribe_async(query)' instead.rcr_N)rarrrZ ensure_future __anext__rStopAsyncIterationKeyboardInterrupt Exception GeneratorExitaclosecancelshutdown_asyncgens) r;rFr1r%rdrer`async_generatorgenerator_taskrs r=rrs ##%??$$  B $   3%!5      ")!6!6#--/d" ++"  "  !9m<   ! !/"8"8": F  ! ! #  # #D$;$;$= >  s%AC9;B C6 C9A(C66C9c# [UR[5(dS5eU U(a[SSU0UD6UlO[ US9UlURR 5IShvN UR(a3UR(d"URR5IShvN UR$NUN![a% URR5IShvN ef=f7f)aConnect asynchronously with the underlying async transport to produce a session. That session will be a permanent auto-reconnecting session if :code:`reconnecting=True`. If you call this method, you should call the :meth:`close_async ` method for cleanup. :param reconnecting: if True, create a permanent reconnecting session :param \**kwargs: additional arguments for the :meth:`ReconnectingAsyncClientSession init method `. zBOnly a transport of type AsyncTransport can be used asynchronouslyclientrNrh) r7r-rReconnectingAsyncClientSessionrwAsyncClientSessionconnectr.r+ fetch_schemarclose)r; reconnectingres r= connect_asyncClient.connect_asyncs" NNN   P O P  9PPPDL-T:DLll""$$$ // ll//111|| % 2 ,,$$& & &   sHA.C<0C1C<6?C 5C6C : C<C 'C91C42C99C<cT# URR5IShvN gN7f)zBClose the async transport and stop the optional reconnecting task.N)rwrrCs r= close_asyncClient.close_asyncsll  """s (&(c># UR5IShvN $N7frg)rrCs r= __aenter__Client.__aenter__"s''))))s c@# UR5IShvN gN7frg)r)r;exc_typeexctbs r= __aexit__Client.__aexit__%s   s c[UR[5(aS5e[US5(d[ US9Ul[UR [5(deUR R 5 UR(a+UR(dUR R5 UR $![a UR R5 ef=f)zConnect synchronously with the underlying sync transport to produce a session. If you call this method, you should call the :meth:`close_sync ` method for cleanup. zSOnly a sync transport can be used. Use 'async with Client(...) as session:' insteadrwr) r7r-rhasattrSyncClientSessionrwrr.r+rrrrCs r= connect_syncClient.connect_sync(sdnnn==  @ = tY'',D9DL$,,(9::::  //  ))+||  LL     s propertyrDrrrrR staticmethodrZAbstractEventLooprarr rrjr r|rrrurrrr rrrrrrrrr__static_attributes__rhr@r=r(r(/s,7;6:@D,1-179$)# !T#sM123T# 23 T# E)^";<= T# &* T#%TNT#"%U "34T#"T#T#T#T#l($((''4'> /> >&W66" /2'*/2 &d^  tn  &en  c3h /2'* &d^  tn  &dm   /2'* 55&d^ 5 tn 5 # 55 tCH~. /55/3'+%* &d^  tn  #  tCH~. /& /3'+/2 #~&#&d^ # tn # &en ## d38n ## /3'+ $~&$&d^ $ tn $ &dm $$ o $$ /3'+ A~&A&d^ A tn A # AA tDcN#T/%:: ;AA/3'+%* ~&&d^  tn  #  tDcN#T/%:: ;& /2'*/2 &d^  tn  &en  c3h /2'* &d^  tn  &dm   /2'* 55&d^ 5 tn 5 # 55 tCH~. /55/3'+%* &d^  tn  #  tCH~. /& /3'+/2 #~&#&d^ # tn # &en ## d38n ## /3'+ $~&$&d^ $ tn $ &dm $$ o $$ /3'+ A~&A&d^ A tn A # AA tDcN#T/%:: ;AA/3'+%* ~&&d^  tn  #  tDcN#T/%:: ;& /2'*/2 &d^  tn  &en  c3h /2'* &d^  tn  &dm   /2'* 55&d^ 5 tn 5 # 55 tCH~. /55/3'+%* ::&d^ : tn : # :: tCH~. /:x /3'+/2 #~&#&d^ # tn # &en ## d38n ## /3'+ $~&$&d^ $ tn $ &dm $$ o $$ /3'+ A~&A&d^ A tn A # AA tDcN#T/%:: ;AA/3'+%* :~&:&d^ : tn : # :: tDcN#T/%:: ;:x /2'*/2 33&d^ 3 tn 3 &en 33 S#X, -33 /2'* 44&d^ 4 tn 4 &dm 44 - .44 /2'*    &d^  tn  #     tCH~t+,n_d=R.SS     /3'+%* &d^  tn  #  tCH~t+,n_d=R.SS 0 /2'*/2 44&d^ 4 tn 4 &en 44 4S>4- .44 /2'* 55&d^ 5 tn 5 &dm 55 ?D$. /55 /2'*    &d^  tn  #     $sCx.$,-y$PT9T/UU     /3'+%* <<&d^ < tn < # << $sCx.$,-y$PT9T/UU <|)V# *! D#r@r(c\rSrSrSrS\4SjrSSS.S\S\\ S \\ S \ S \ 4 S jjr \ S S S S.S\S\\ S \\ S\SS \ S \\\ 44 Sjj5r\ S S S.S\S\\ S \\ S\SS \ S \ 4 Sjj5r\ S S S.S\S\\ S \\ S\ S \ S \\\\ 4\ 44 Sjj5rSSSS.S\S\\ S \\ S\ S \ S \\\\ 4\ 44 SjjrSSSS.S\\S\\ S \\ S\\ S \ S \\ 4 Sjjr\ SSS S.S\\S\\ S \\ S\SS \ S \\\\ 44 Sjj5r\ SSS.S\\S\\ S \\ S\SS \ S \\ 4 Sjj5r\ SSS.S\\S\\ S \\ S\ S \ S \\\\\ 4\\ 44 Sjj5rSSSS.S\\S\\ S \\ S\ S \ S \\\\\ 4\\ 44 SjjrS%SjrS\S \4SjrS rS!rS%S"jr\S#5rS$rg)&ri[zAn instance of this class is created when using :code:`with` on the client. It contains the sync method execute to send queries on a sync transport using the same session. rcXlgz;:param client: the :class:`client ` usedNrr;rs r=r>SyncClientSession.__init__b r@NrmrFr1r%rerAc [X5nURR(arURRU5 URbJU(dUc@URR (a%UR URR5nURR(a"URU5nUR5nOURR"U40UD6nURR(ahU(dUc^URR(aC[URRURURUR S9UlU$)aKExecute the provided request synchronously using the sync transport, returning an ExecutionResult object. :param request: GraphQL request as a :class:`GraphQLRequest ` object. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. The extra arguments are passed to the transport execute method.operation_name)rrr+rvariable_valuesr1serialize_variable_valuesrD_execute_futurerr-rur2parse_result_fnrIrPrr;rFr1r%re future_resultrs r=_executeSyncClientSession._executefs.-W= ;;   KK  )&&2&'/DKK4S4S%?? @R@RSG ;; ' ' 009M"))+F^^++F ;;   49R9R-KK&&$$KK#*#9#9   r@.rcrdFc grgrhris r=ruSyncClientSession.executerlr@Tc grgrhris r=rurror@c grgrhris r=rurrqr@c UR"U4UUS.UD6nUR(a=[[UR5URURUR S9eURcS5eU(aU$UR$)aExecute the provided request synchronously using the sync transport. Raises a TransportQueryError if an error has been returned in the ExecutionResult. :param request: GraphQL query as :class:`GraphQLRequest `. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. :param get_execution_result: return the full ExecutionResult instance instead of only the "data" field. Necessary if you want to get the "extensions" field. The extra arguments are passed to the transport execute method.rmrNEc grgrhr{s r=rSyncClientSession.execute_batch.r~r@c grgrhr{s r=rr9rr@c grgrhr{s r=rrDrr@c UR"U4UUS.UD6nUHenUR(a=[[UR5URURUR S9eURbM`S5e U(aU$[ [[[[4UVs/sHowRPM sn5$s snf)a)Execute multiple GraphQL requests in a batch, using the sync transport. This method sends the requests to the server all at once. Raises a TransportQueryError if an error has been returned in any ExecutionResult. :param requests: List of requests that will be executed. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. :param get_execution_result: return the full ExecutionResult instance instead of only the "data" field. Necessary if you want to get the "extensions" field. The extra arguments are passed to the transport execute method.rmrNr  rrOr r&rPrQrr r r8rr;ryr1r%rdrerrs r=rrOs6%%  3%   F}})%fmm4!==%00  ' NM N' NDc3h(W*MW6;;W*MNN*Ms-C cSnU(Gd{/nURR5nUcGOZURU5 URR5URR S- :a*[ R"URR5 [URR S- 5HVnURR5(a O6URR5nUcSn OURU5 MX UVVs/sHupTUPM nnnUVVs/sHupGUPM nnnURUSSSS9n [X5HupURU 5 M U(dGM{UR R#5 gs snnfs snnf![a&n UHnURU 5 M Sn A GMSn A ff=f)zLmain loop of the thread used to wait for requests to execute them in a batchFNrTr) batch_queuegetappendqsizerr4timesleepr3rangeemptyrr set_exceptionzip set_result_batch_thread_stopped_eventset) r; stop_looprequests_and_futuresrequest_and_future_rFryfuturefuturesrrrs r= _batch_loopSyncClientSession._batch_loops IK @D@P@P@T@T@V !) ' '(: ;%%'$++*?*?!*CC 4;;5564;;00145##))++%)%5%5%9%9%;"%- $I$++,>?63GG2FJG2FHG/CD/C)!v/CGD 151D1D(-!&&+ 2E2#&g"7!!&)#8S)Z ((,,.+HD %F((-& s$F!3F'F-- G7GGc[US5(dS5eUR(aS5e[5nURR X45 U$)If batching is enabled, this method will put a request in the batching queue instead of executing it directly so that the requests could be put in a batch. rBatching is not enabledz Batching thread has been stopped)r_batch_thread_stop_requestedrrputr;rFr0s r=r!SyncClientSession._execute_futuresUt]++F-FF+44X6XX4 g./ r@cURR(aX[5UlSUl[ 5Ul[URSS9Ul URR5 URR5 g)zUConnect the transport and initialize the batch threading loop if batching is enabled.FT)targetdaemonN) rrDrrr7rr*rr2 _batch_threadstartr-rrCs r=rSyncClientSession.connectsd ;; ' '&+gD 05D -/4wD ,!'t/?/?!MD     $ $ &  r@c[US5(a<SUlURRS5 URR 5 UR R5 g)zClose the transport and cleanup the batching thread if batching is enabled. Will wait until all the remaining requests in the batch processing queue have been executed. r*TN)rr7rr8r*waitr-rrCs r=rSyncClientSession.closesT 46 7 715D -     &  , , 1 1 3 r@c[S0URRD6nURR [ U55nURR U5 gzFetch the GraphQL schema explicitly using introspection. Don't use this function and instead set the fetch_schema_from_transport attribute to TrueNrhr$rr/r-rurrRr;introspection_queryrLs r=rSyncClientSession.fetch_schemasQ : kk,,  >>11.AT2UV 445EFr@c.URR$rgrr-rCs r=r-SyncClientSession.transport{{$$$r@)r>r7r*rrrAN)r:rrrrr(r>rrrrrrrr r r8rurr rrr2rrrrrrr-rrhr@r=rr[s v/3'+ 88&d^ 8 tn 8  8 8t /2'*/2 &d^  tn  &en  c3h /2'* &d^  tn  &dm   /2'* 55&d^ 5 tn 5 # 55 tCH~. /55/3'+%* 22&d^ 2 tn 2 # 22 tCH~. /2p/3'+,0 7~&7&d^ 7 tn 7 $D> 77 o 7r /3'+/2 #~&#&d^ # tn # &en ## d38n ## /3'+ $~&$&d^ $ tn $ &dm $$ o $$ /3'+ A~&A&d^ A tn A # AA tDcN#T/%:: ;AA/3'+%* 3O~&3O&d^ 3O tn 3O # 3O3O tDcN#T/%:: ;3Oj3/j  !" G%%r@rc~\rSrSrSrS\4SjrSSS.S\S\\ S \\ S \ S \ \ S44 S jjr \S S S S.S\S\\ S \\ S\SS \ S \ \\\ 4S44 Sjj5r\S S S.S\S\\ S \\ S\SS \ S \ \ S44 Sjj5r\S S S.S\S\\ S \\ S\ S \ S \\ \\\ 4S4\ \ S444 Sjj5rSSSS.S\S\\ S \\ S\ S \ S \\ \\\ 4S4\ \ S444 SjjrSSS.S\S\\ S \\ S \ S \ 4 Sjjr\S S S S.S\S\\ S \\ S\SS \ S \\\ 44 Sjj5r\S S S.S\S\\ S \\ S\SS \ S \ 4 Sjj5r\S S S.S\S\\ S \\ S\ S \ S \\\\ 4\ 44 Sjj5rSSSS.S\S\\ S \\ S\ S \ S \\\\ 4\ 44 SjjrSSSS.S\\S\\ S \\ S\\ S \ S \\ 4 Sjjr\SSS S.S\\S\\ S \\ S\SS \ S \\\\ 44 Sjj5r\SSS.S\\S\\ S \\ S\SS \ S \\ 4 S jj5r\SSS.S\\S\\ S \\ S\ S \ S \\\\\ 4\\ 44 S!jj5rSSSS.S\\S\\ S \\ S\ S \ S \\\\\ 4\\ 44 S"jjrS,S#jrS\S \R64S$jrS%rS&rS'rS(r S,S)jr!\"S*5r#S+r$g)-rizAn instance of this class is created when using :code:`async with` on a :class:`client `. It contains the async methods (execute, subscribe) to send queries on an async transport using the same session. rcXlgrrrs r=r>AsyncClientSession.__init__rr@NrmrFr1r%rerAc "# [X5nURR(arURRU5 URbJU(dUc@URR (a%UR URR5nURR"U40UD6nXPl UShvN nURR(ahU(dUc^URR(aC[URRURURURS9Ul U7v MN UR5IShvN g!UR5IShvN f=f7f)aCoroutine to subscribe asynchronously to the provided request asynchronously using the async transport, returning an async generator producing ExecutionResult objects. * Validate the query with the schema if provided. * Serialize the variable_values if requested. :param request: GraphQL request as a :class:`GraphQLRequest ` object. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. The extra arguments are passed to the transport subscribe method.Nr)rrr+rrr1rr-r _generatorr2rrIrPrr)r;rFr1r%reinner_generatorrs r= _subscribeAsyncClientSession._subscribes16-W= ;;   KK  )&&2&'/DKK4S4S%?? @R@RSG NN $ $   * + / f;;%%#$,1J1J&5 KK..#,,"KK+2+A+A '   "((* * */((* * *s[B`. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. :param get_execution_result: yield the full ExecutionResult instance instead of only the "data" field. Necessary if you want to get the "extensions" field. The extra arguments are passed to the transport subscribe method.rmNrN)rUrOr r&rPrQr)r;rFr1r%rdrerTrs r=rrXms8BF B 3%B  B  + / *f==-)&--8%}}#[[#)#4#4 [[,+$ $kk) * "((* * */((* * *s[CB>B#B!B#AB>B>!B##B>$C7B:8C>CCCCc# [X5nURR(arURRU5 URbJU(dUc@URR (a%UR URR5nURR(a$URU5IShvN nUIShvN nOM[URR5 URR"U40UD6IShvN nSSS5 URR(ahU(dUc^URR(aC[URRURWR UR"S9UlW$NNN!,(df  N=f7f)aCoroutine to execute the provided request asynchronously using the async transport, returning an ExecutionResult object. * Validate the query with the schema if provided. * Serialize the variable_values if requested. :param request: GraphQL request as a :class:`GraphQLRequest ` object. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. The extra arguments are passed to the transport execute method.Nr)rrr+rrr1rrDrrr0r-rur2rrIrPrrs r=rAsyncClientSession._executesH4-W= ;;   KK  )&&2&'/DKK4S4S%?? @R@RSG ;; ' '"&"6"6w"??M((FDKK778#~~55  9 ;;   49R9R-KK&&$$KK#*#9#9   )@(98sOCG F, GF.$G9!F2F0F2BG.G0F22 G<Gc # g7frgrhris r=ruAsyncClientSession.executerrc # g7frgrhris r=rur_rrc # g7frgrhris r=rur_rrc8# UR"U4UUS.UD6IShvN nUR(a=[[UR5URURUR S9eURcS5eU(aU$UR$N{7f)aCoroutine to execute the provided request asynchronously using the async transport. Raises a TransportQueryError if an error has been returned in the ExecutionResult. :param request: GraphQL query as :class:`GraphQLRequest `. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. :param get_execution_result: return the full ExecutionResult instance instead of only the "data" field. Necessary if you want to get the "extensions" field. The extra arguments are passed to the transport execute method.rmNrNr r r s r=rur_s6}}  3%     ==%!&--0}}[[!,,   KK # J I J # M{{/ sBBAE%0"E,E*BE,c # g7frgrhr{s r=r AsyncClientSession.execute_batchqrrc # g7frgrhr{s r=rrf|rrc # g7frgrhr{s r=rrfrrc# UR"U4UUS.UD6IShvN nUHenUR(a=[[UR5URURUR S9eURbM`S5e U(aU$[ [[[[4UVs/sHowRPM sn5$Ns snf7f)a*Execute multiple GraphQL requests in a batch, using the async transport. This method sends the requests to the server all at once. Raises a TransportQueryError if an error has been returned in any ExecutionResult. :param requests: List of requests that will be executed. :param serialize_variables: whether the variable values should be serialized. Used for custom scalars and/or enums. By default use the serialize_variables argument of the client. :param parse_result: Whether gql will deserialize the result. By default use the parse_results argument of the client. :param get_execution_result: return the full ExecutionResult instance instead of only the "data" field. Necessary if you want to get the "extensions" field. The extra arguments are passed to the transport execute method.rmNrNr rrs r=rrfs6++  3%    F}})%fmm4!==%00  ' NM N' NDc3h(W*MW6;;W*MNN1 0+Ns(CCA"C4C7C CCcX# SnU(Gd/nURR5IShvN nUcGOaURU5 URR5URR S- :a2[ R"URR5IShvN [URR S- 5H6nURR5nUcSn OURU5 M8 UVVs/sHupTUPM nnnUVVs/sHupGUPM nnnURUSSSS9IShvN n [X5H-upUR5(aMURU 5 M/ U(dGMUR$R'5 gGNGN ![ Ra  Mf=fs snnfs snnfN![ a;n UH+nUR5(aMUR#U 5 M- Sn A NSn A ff=f7f)zJMain loop of the task used to wait for requests to execute them in a batchFNrTr)rr r!r"rr4rZr$r3r% get_nowait QueueEmptyrr( cancelledr)rr'_batch_task_stopped_eventr+) r;r,r-r.r/rFryr0r1rrrs r=r2AsyncClientSession._batch_loops PR &&**,, ") ' '(: ;%%'$++*?*?!*CCmmDKK$>$>???4;;00145 )-)9)9)D)D)F&)1$( (//0BC6"3GG2FJG2FHG/CD/C)!v/CGD 27;7J7J(-!&&+ 8K82'*'&;NF!++--))&1'!AAAAc# [S0URRD6nURR [ U55IShvN nURR U5 gN 7frErFrGs r=rAsyncClientSession.fetch_schemaGsc : kk,, "&!7!7 . /"   445EF  sAA, A* !A,c.URR$rgrKrCs r=r-AsyncClientSession.transportUrMr@)rurqrnrSrrrN)%r:rrrrr(r>rrrrrrrUrr r r8rrrrur rrr2rZrrrvryrrrrr-rrhr@r=rrsv/3'+ D+D+&d^ D+ tn D+  D+ - .D+L /2'*/2 33&d^ 3 tn 3 &en 33 S#X, -33 /2'* 44&d^ 4 tn 4 &dm 44 - .44 /2'*    &d^  tn  #     tCH~t+,n_d=R.SS     /3'+%* 5+5+&d^ 5+ tn 5+ # 5+5+ tCH~t+,n_d=R.SS 5+v/3'+ ==&d^ = tn =  = =~ /2'*/2 &d^  tn  &en  c3h /2'* &d^  tn  &dm   /2'* 55&d^ 5 tn 5 # 55 tCH~. /55/3'+%* 22&d^ 2 tn 2 # 22 tCH~. /2p/3'+,0 7~&7&d^ 7 tn 7 $D> 77 o 7r /3'+/2 #~&#&d^ # tn # &en ## d38n ## /3'+ $~&$&d^ $ tn $ &dm $$ o $$ /3'+ A~&A&d^ A tn A # AA tDcN#T/%:: ;AA/3'+%* 3O~&3O&d^ 3O tn 3O # 3O3O tDcN#T/%:: ;3OjE-N  G 8 % G%%r@r _CallableT.)boundc $^\rSrSrSrSSS.S\S\\\4S\\\44Sjjr S r S r S r S r S rSSS.S\S\\S\\S\S\4 U4SjjjrSSS.S\S\\S\\S\S\4 SjjrSSS.S\S\\S\\S\S\\S44 U4SjjjrSrU=r$)ri^a(An instance of this class is created when using the :meth:`connect_async ` method of the :class:`Client ` class with :code:`reconnecting=True`. It is used to provide a single session which will reconnect automatically if the connection fails. T) retry_connect retry_executerrrcXlSUl[R"5Ul[R"5UlUSLa.[ R"[ R[SS9Ul O&USLa SUl O[U5(deX l USLa0[ R"[ R[SSS 9Ul O&USLa S Ul O[U5(deX0l URUR5UlURURR 5Ulg) a :param client: the :class:`client ` used. :param retry_connect: Either a Boolean to activate/deactivate the retries for the connection to the transport OR a backoff decorator to provide specific retries parameters for the connections. :param retry_execute: Either a Boolean to activate/deactivate the retries for the execute method OR a backoff decorator to provide specific retries parameters for this method. NT<) max_valueFcU$rgrhr|s r=9ReconnectingAsyncClientSession.__init__..1r@c"[U[5$rg)r7r rs r=rrs A/B!Cr@) max_triesgiveupcU$rgrhrs r=rrrr@)r _connect_taskrZr_reconnect_request_event_connected_eventbackoff on_exceptionexporrcallabler _execute_once_execute_with_retriesr-r_connect_with_retries)r;rrrs r=r>'ReconnectingAsyncClientSession.__init__gs   !(/ % '  D ")!5!5 "D  e #!,D M** **!.  D !(!5!5 C "D  e #!,D M** **!. &*%7%78J8J%K"%)%7%78N8N%O"r@cp# UR5IShvN URR5 URR5 URR5 URR 5IShvN UR R5IShvN MNN*N 7f)zCoroutine used for the connection task. - try to connect to the transport with retries - send a connected event when the connection has been made - then wait for a reconnect request to try to connect again N)rrr+clearrrBr-rrCs r=_connection_loop/ReconnectingAsyncClientSession._connection_loops,,. . .  ! ! % % '  ! ! ' ' )  ) ) / / 1//446 6 6..&&( ( ( / 7 (s4B6B0A/B6B2!B6)B4*B62B64B6c# UR(a[RS5 g[R"UR 55UlUR R5IShvN gN7f)zbStart the task responsible to restart the connection of the transport when requested by an event. zconnect task already started!N)rlogwarningrZrrrrBrCs r=start_connecting_task4ReconnectingAsyncClientSession.start_connecting_tasksQ    KK7 8!(!6!6t7L7L7N!OD '',,. . .sA.A80A61A8cj# URb"URR5 SUlgg7f)zStop the connecting task.N)rrrCs r=stop_connecting_task3ReconnectingAsyncClientSession.stop_connecting_tasks0    )    % % '!%D  *s13ct# UR5IShvN UR5IShvN gNN7f)zQStart the connect task and initialize the batch task loop if batching is enabled.N)rvrrCs r=r&ReconnectingAsyncClientSession.connects3   ((*** !*s848688c# UR5IShvN UR5IShvN URR5IShvN gN?N)N 7f)zKStop the connect task and cleanup the batching task if batching is enabled.N)ryrr-rrCs r=r$ReconnectingAsyncClientSession.closesL!!###'')))nn""$$$ $)$s1AAAA!AAAAANrmrFr1r%rerAc># [TU]"U4UUS.UD6IShvN nU$N![a URR 5 ef=f7f)z|Same Coroutine as parent method _execute but requesting a reconnection if we receive a TransportConnectionFailed exception. rmN)superrrrr+)r;rFr1r%reanswer __class__s r=r,ReconnectingAsyncClientSession._execute_oncesh  7+$7) F  )   ) ) - - /  s%A%#%A%&A  AcJ# UR"U4UUS.UD6IShvN $N7f)zSame Coroutine as parent, but with optional retries and requesting a reconnection if we receive a TransportConnectionFailed exception. rmN)r)r;rFr1r%res r=r'ReconnectingAsyncClientSession._executes<//  3%      s #!#c &># [TU]"U4UUS.UD6nUShvN nU7v MN O)![a URR 5 ef=fUR 5IShvN g!UR 5IShvN f=f7f)zSame Async generator as parent method _subscribe but requesting a reconnection if we receive a TransportConnectionFailed exception. rmN)rrUrrr+r)r;rFr1r%rerTrrs r=rU)ReconnectingAsyncClientSession._subscribesBGAS B 3%B  B  + / f  )   ) ) - - /  !0"((* * */((* * *s[B/-+-/-/A3&AA3B,A/-B3BB BB)rrrrrrrr)r:rrrrr(rr _Decoratorr>rrrrrrrrrrrrrUr __classcell__)rs@r=rr^sF2615 5P5PT:-. 5P T:-. 5Pn), /& +%/3'+ &d^  tn    :/3'+   &d^  tn      0/3'+ ++&d^ + tn +  + - .++r@r)?rZloggingr#rWconcurrent.futuresrqueuer threadingrrtypingrrr r r r r rrrrrrranyiorgraphqlrrrrrrgraphql_requestrrtransport.async_transportrtransport.exceptionsrr transport.local_schemar!transport.transportr" utilitiesr#r$r%rutilsr& getLoggerr:rr(rrrrrrhr@r=rs %# H5P8*G6$ !i i XZ%Z%z _ %_ %D\#s(); < zlJ. / A+%7A+r@