ޠj(SSKJr SSKJr SSKJr SSKJr SSKJ r J r Sr Sr S r S rS rS rS rSr"SS5r"SS\5rg)) DataError) ResponseError)VersionMismatchException) ExecutionPlan)AsyncQueryResult QueryResultz GRAPH.PROFILEzGRAPH.RO_QUERYz GRAPH.QUERYz GRAPH.DELETEz GRAPH.SLOWLOGz GRAPH.CONFIGz GRAPH.LISTz GRAPH.EXPLAINcp\rSrSrSrSrSSjrSrSrSr S r S r S r SS jr S rSSjrSSjrSrg) GraphCommandszRedisGraph Commandsc [UR5S:Xa[UR5S:XagSnURR5Hup#U[ U5S-- nM USR URVs/sHn[ U5PM sn5- nUSS:XaUSSnUR U5$s snf)z Create entire graph. rNzCREATE ,)lennodesedgesitemsstrjoinquery)selfr_nodeedges W/var/www/html/gaurav/venv/lib/python3.13/site-packages/redis/commands/graph/commands.pycommitGraphCommands.commits tzz?a C Oq$8zz'')GA SY_ $E* <3t9<== 9 #2JEzz%  =sC Nc>UnURU5U-nU(a[nOU(a[O[nXpRUS/n[ U[ 5(aURSU/5 OUb [S5eUR"U6n [X U5$![a3n S[U 5;aU(aURXUSS9sSn A $U eSn A f[a=n U RUlUR!5 URXX45sSn A $Sn A ff=f)a Executes a query against the graph. For more information see `GRAPH.QUERY `_. # noqa Args: q : str The query. params : dict Query parameters. timeout : int Maximum runtime for read queries in milliseconds. read_only : bool Executes a readonly query if set to True. profile : bool Return details on results produced by and time spent in each operation. --compacttimeoutN+Timeout argument must be a positive integerunknown commandF read_only)_build_params_header PROFILE_CMD RO_QUERY_CMD QUERY_CMDname isinstanceintextend Exceptionexecute_commandr rrrrversion_refresh_schema rqparamsr r$profilercmdcommandresponsees rrGraphCommands.query(s*))&1E9 C"+,C 5+6 gs # # NNIw/ 0  IJ J =++W5Htw7 7  CF*yzz!WzFFG' =99DL  "::a< <  =s6?B D$&C DC D2DDDcDSnU[U5- nURU5$)z Merge pattern. zMERGE )rr)rpatternrs rmergeGraphCommands.mergebs& Wzz%  cbUR5 UR[UR5$)zd Deletes graph. For more information see `DELETE `_. # noqa ) _clear_schemar. DELETE_CMDr)rs rdeleteGraphCommands.deleteks' ##J ::r>c@UR5 0Ul/UlgzD Commit the graph and reset the edges and the nodes to zero length. NrrrrBs rflushGraphCommands.flushts   r>c [S5e)zInternal only. Not supported.zVGRAPH.BULK is internal only. Use https://github.com/redisgraph/redisgraph-bulk-loader.)NotImplementedError)rkwargss rbulkGraphCommands.bulk|s! H  r>c"URUSS9$)aB Execute a query and produce an execution plan augmented with metrics for each operation's execution. Return a string representation of a query execution plan, with details on results produced by and time spent in each operation. For more information see `GRAPH.PROFILE `_. # noqa T)r4)r)rrs rr4GraphCommands.profileszz%z..r>cBUR[UR5$)a Get a list containing up to 10 of the slowest queries issued against the given graph ID. For more information see `GRAPH.SLOWLOG `_. # noqa Each item in the list has the following structure: 1. A unix timestamp at which the log entry was processed. 2. The issued command. 3. The issued query. 4. The amount of time needed for its execution, in milliseconds. )r. SLOWLOG_CMDr)rBs rslowlogGraphCommands.slowlogs##K;;r>cU(aSOSU/nUb$U(aURU5 O [S5eUR"[/UQ76$)aB Retrieve or update a RedisGraph configuration. For more information see ``__. Args: name : str The name of the configuration value : The value we want to set (can be used only when `set` is on) set : bool Turn on to set a configuration. Default behavior is get. SETGETz3``value`` can be provided only when ``set`` is True)appendrr. CONFIG_CMD)rr)valuesetr3s rconfigGraphCommands.configsO%E40   e$I##J888r>c,UR[5$)z} Lists all graph keys in the keyspace. For more information see `GRAPH.LIST `_. # noqa )r.LIST_CMDrBs r list_keysGraphCommands.list_keyss ##H--r>cURU5U-nUR[URU5n[ US[ 5(aUVs/sHoDR 5PM nnSRU5$s snf) Get the execution plan for given query, GRAPH.EXPLAIN returns an array of operations. Args: query: the query that will be executed params: query parameters r r%r. EXPLAIN_CMDr)r*bytesdecoderrrr3planbs rexecution_planGraphCommands.execution_plansm))&1E9##KEB d1gu % %(,-1HHJD-yy.sA=cURU5U-nUR[URU5n[ U5$)a Get the execution plan for given query, GRAPH.EXPLAIN returns ExecutionPlan object. For more information see `GRAPH.EXPLAIN `_. # noqa Args: query: the query that will be executed params: query parameters r%r.rfr)rrrr3rjs rexplainGraphCommands.explains<))&1E9##KEBT""r>rrr/NNFF)NFN)__name__ __module__ __qualname____firstlineno____doc__rrr<rCrHrMr4rSr\r`rlrq__static_attributes__r>rr r sB!&8=t!; / <90. #r>r c8\rSrSrSSjrS SjrS SjrSrSrg) AsyncGraphCommandsNc# UnURU5U-nU(a[nOU(a[O[nXpRUS/n[ U[ 5(aURSU/5 OUb [S5eUR"U6IShvN n [5RX U5IShvN $N&N![a<n S[U 5;a&U(aURXUSS9IShvN sSn A $U eSn A f[aFn U R UlUR#5 URXX45IShvN sSn A $Sn A ff=f7f)a Executes a query against the graph. For more information see `GRAPH.QUERY `_. # noqa Args: q : str The query. params : dict Query parameters. timeout : int Maximum runtime for read queries in milliseconds. read_only : bool Executes a readonly query if set to True. profile : bool Return details on results produced by and time spent in each operation. rr Nr!r"Fr#)r%r&r'r(r)r*r+r,r-r.r initializerrrrr/r0r1s rrAsyncGraphCommands.querys**))&1E9 C"+,C 5+6 gs # # NNIw/ 0  IJ J C!117;;H)+66twOO O<O  CF*y!ZZ7eZLLLLG' C99DL  "AwBBB B  CsA>EB>B:!B>5B<6B>9E:B><B>> E*C?2C53C?7E8E=C?? E 6E EE EE EEc # URU5U-nUR[URU5IShvN n[ US[ 5(aUVs/sHoDR 5PM nnSRU5$NKs snf7f)rcNrrdreris rrl!AsyncGraphCommands.execution_plansw))&1E9))+tyy%HH d1gu % %(,-1HHJD-yyI-s!9BB BB 4B Bc# URU5U-nUR[URU5IShvN n[ U5$N7f)z Get the execution plan for given query, GRAPH.EXPLAIN returns ExecutionPlan object. Args: query: the query that will be executed params: query parameters Nrorps rrqAsyncGraphCommands.explain%sH))&1E9))+tyy%HHT""Is9A A A c\# UR5IShvN 0Ul/UlgN7frFrGrBs rrHAsyncGraphCommands.flush3s)kkm   s ,*,rsrtru) rvrwrxryrrlrqrHr{r|r>rr~r~s8Ct #r>r~N)redisrredis.exceptionsr exceptionsrrlr query_resultrr r&r'r(rArRrYr_rfr r~r|r>rrsW*0)7       E#E#P__r>