ޠjVHSSKr"SS5r"SS5r"SS5rg)Nc\rSrSrSrSrSrg) ProfileStatsz: ProfileStats, runtime execution statistics of operation. cXlX lgN)records_producedexecution_time)selfrr s ]/var/www/html/gaurav/venv/lib/python3.13/site-packages/redis/commands/graph/execution_plan.py__init__ProfileStats.__init__ s 0,)r rN)__name__ __module__ __qualname____firstlineno____doc__r __static_attributes__rr rrs -rrcN\rSrSrSrS SjrSrSrS\S\ 4S jr S\ 4S jr S r g) Operationz4 Operation, single operation within execution plan. Nc6XlX lX0l/Ulg)z Create a new operation. Args: name: string that represents the name of the operation args: operation arguments profile_stats: profile statistics N)nameargs profile_statschildren)r rrrs r r Operation.__init__s  * rc[U[5(aXLa [S5eURR U5 U$)Nzchild must be Operation) isinstancer Exceptionrappend)r childs r append_childOperation.append_child!s6%++t}56 6 U# rc,[UR5$r)lenr)r s r child_countOperation.child_count(s4==!!roreturnc[U[5(dgURUR:H=(a URUR:H$)NF)r rrr)r r*s r __eq__Operation.__eq__+s7!Y''yyAFF":tyyAFF'::rc^URcSOSUR-nURU3$)Nz | )rr)r args_strs r __str__Operation.__str__1s.*2 0A))XJ''r)rrrr)NN)rrrrrr r$r(objectboolr-strr2rrrr rrs5 ";;4; ((rrcP\rSrSrSrSrSrS\4SjrS\ S\ 4Sjr S r S r S rg ) ExecutionPlan6z* ExecutionPlan, collection of operations. c[U[5(d [S5e[US[5(aUVs/sHo"R 5PM nnXlUR 5Ulgs snf)z Create a new execution plan. Args: plan: array of strings that represents the collection operations the output from GRAPH.EXPLAIN zplan must be an arrayrN)r listr!bytesdecodeplan_operation_treestructured_plan)r r>bs r r ExecutionPlan.__init__;sa$%%34 4 d1gu % %(,-1HHJD- #335.sA3cX:wagUR5UR5:wag[UR55H6nURURUURU5(aM6 g g)zc Compare execution plan operation tree Return: True if operation trees are equal, False otherwise FT)r(range_compare_operationsr)r root_aroot_bis r rE!ExecutionPlan._compare_operationsLst      6#5#5#7 7v))+,A++FOOA,>PQ@RSS-rr+cPSnSnURUR[X5$)Nc SRUVVs/sHnUR5HnSU-PM M! snn5$s snnf)N  )join splitlines) str_children str_childlines r aggraget_str+ExecutionPlan.__str__..aggraget_strcsO99&2%1 ) 4 4 6TM 6"%1 s%> cUSU3$)NrLr)xys r combine_str*ExecutionPlan.__str__..combine_strlsS1#; r)_operation_traverser@r6)r rSrXs r r2ExecutionPlan.__str__bs.  ''  #|  rr*c[U[5(dgURnURnURX#5$)zVCompares two execution plans Return: True if the two plans are equal False otherwise F)r r8r@rE)r r*rFrGs r r-ExecutionPlan.__eq__ss? !]++%%""''77rc U"U5n[UR5S:XaU$URVs/sHnURXbX45PM nnU"XS"U55$s snf)a9 Traverse operation tree recursively applying functions Args: op: operation to traverse op_f: function applied for each operation aggregate_f: aggregation function applied for all children of a single operation combine_f: combine function applied for the operation result and the children result r)r'rrZ)r opop_f aggregate_f combine_fop_resr#rs r rZ!ExecutionPlan._operation_traversesob r{{ q M  [[(E((kM(  V[%:; ; sAc~SnSn/nSnSnU[UR5:GaURUnURS5nXr:XaGU"URS55nU(a!UR 5nUR U5 UnUS- nOXrS-:XaFU"URS55nUR U5 UR U5 UnUS- nUS- nO>Xr:a.X'- S-n [U 5Hn UR 5nM X)-nO [S5eU[UR5:aGMUS$)z7Build the operation tree from the string representationrNcSnUSR5nURS5 [U5S:aSUS;a[[R "SUS5R S55n[[R "SUS5R S55n[X45nURS5 [U[U5S:XaSU5$USR5U5$)NrzRecords producedzRecords produced: (\d+)zExecution time: (\d+.\d+) ms) strippopr'intresearchgroupfloatrr)rrrrr s r _create_operation8ExecutionPlan._operation_tree.._create_operations M7==?D HHQK4y1}!3tBx!?#&II8$r(CII!L$ "'II>RIOOPQR"!--= N  c$i1nd= 26q'--/= rrM|rhzcorrupted plan) r'r>countsplitrjr$r"rDr!) r rHlevelstackcurrentrp current_opop_levelr# levels_back_s r r?ExecutionPlan._operation_treesE  $#dii. 1J!''/H ***:*:3*?@#iikG((/QQY&***:*:3*?@$$U+ W% Q!$.2 {+A#iikG,$ 011;#dii. <Qxr)r>r@N)rrrrrr rEr6r2r4r5r-rZr?rrrr r8r86s:6",  "8848 <.9rr8)rlrrr8rrr r}s) --%(%(P]]r