^hE<SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r J r J r J r Jr SSKrSSKJr SSKJr SSKJr SSKJrJr SSKJrJrJrJrJr SSK J!r! SS K"J#r# SS K$J%r% SS K&J'r'J(r( SS K)J*r*J+r+ SS K,J-r- SSK.J/r/ \ (aSSK0J1r1 Sr2SRg5r4\5r6Sr7SCSjr8S\9S\ \94Sjr:S\9S\ \94Sjr;S\9S\ \94SjrS\9S\9SS4Sjr?\/"S 5r@\@RS!S"\BSS#9 \@RS$S%S&S'9 \@RS(S&S'9 \@RS)S"\9SS#9 \@RS*S&S'9 S\9S\ \94S+jrC\/"S,S-S.9rD\DRS/\9S09 \DRS1S&S'9 \DRS2\BSS39 S\9SS4S4jrE\/"S5S6S.9rF\FRS2\BSS39 S\9SS4S7jrGS\9SS4S8jrHS\9SS4S9jrIS\9SS4S:jrJS\9SS4S;jrKS<\9S\ \ \R4S=jrMS>rNS?rOS\9SS4S@jrPS\9SS4SAjrQS\9SS4SBjrRg)DN) TYPE_CHECKINGIterableOptionalSequenceTypecast) get_ipython)register_line_magic) SymbolRef)register_annotations_directoryregister_annotations_file) ExecutionModeExecutionSchedule FlowDirection HighlightsReactivityMode)cells)Symbol)create_dag_metadata)flowshell)SliceableMixin format_slice)resolve_rval_symbols) MagicParser) NotebookFlowra$Options: [enable|disable] - Toggle dataflow capture. On by default. [deps|show_deps|show_dependencies] : - This will print out the dependencies for given symbol. [code|get_code] : - This will print the backward slice for the given symbol. [waiting|show_waiting]: - This will print out all the global variables that are waiting for newer dependencies. slice : - This will print the code necessary to reconstruct using a dynamic program slicing algorithm. tag : - This will tag the executing cell with the given tag. show_tags: - This will display the current tags of the executing cell. register_annotations : - This will register the annotations in the given directory or file. c:[US[R0UD6 g)Nfile)print_sysstderr)argskwargss M/home/james-whalen/.local/lib/python3.13/site-packages/ipyflow/line_magics.pywarnr%Js D,szz,V,c.^^^[5R5VVs/sH$up[R"U5(dM"UPM& snnmUU4SjmS[4U4SjjnS[SS4Sjn[ U5 [ Ul[ U5$s snnf)Nc>>URSS5nUS;a [U5$US;a [U5$US;a [U5$US;a [ U5$US:Xa [ U5$US;a [ X5$US ;a[R"[5S S 9$US ;a [U5$US :Xa [U5$US:Xa [U5$US;a [U5$US;a [U5$US;a [U5$US:Xa [!U5$US;a [#U5$US;a [%U5$US:XaTR'5TlgUR+S5(a&UR-S5(+TR.lgUR+S5(a&UR-S5(+TR.lgUS:XaBUR+S5nUR+S5nU(dU(aUTR.lgUS:XaSTR.lgUR-S5(a [9U5$US:XaTR;5 gUS :XaTR=5 gUT;a[?S!US"35 g[?[@5 g)#N-_)enabledisableonoff)deps show_depsshow_dependencyshow_dependencies)codeget_code)waiting show_waitingtrace_messages)hlsnohls highlight highlights)dagmake_dagcell_dag make_cell_dag)indentslice make_slice gather_slicetag show_tags)mode exec_mode)schedule exec_scheduleexecution_schedule) directionflow_directionorder flow_order semanticsflow_semantics reactivity)registerregister_tracer) deregisterderegister_tracerclearwarn_ooonolint_ooosyntax_transforms)enabledr-)disabledr.syntax_transforms_onlyTregister_annotationtoggle_reactivity bump_min_forced_reactive_counterzWe have a magic for z , but have not yet registered it)!replacetoggle_dataflowr0r4r6r7set_highlightsjsondumpsrrDrFrG set_exec_modeset_exec_scheduleset_flow_directionset_reactivityrUrW cell_counter min_timestampendswith startswith mut_settingswarn_out_of_order_usageslint_out_of_order_usagessyntax_transforms_enabledr_register_annotationsrarbr%_USAGE)cmdlineis_onis_offflow_line_magic_namess r$_handle make_line_magic.._handleSskk#s# 4 4"3' ' Q QT? " ( (D> ! / /% % $ $!$' ' ? ?!#, , D D::13A> > ; ;d# # E\t9  K T? " ) ) & & G G$T* *   &d+ + L !$' ' 3 3"4( ( 7 7$T* * G^"'"4"4"6E  \\* % %>AnnT>R:RE   7 \\* % %>AnnT>R:RE   7 ' 'MM"34E]]#67F?D""< , ,8URSS5upUS;a[R"SSU5nURSS5upUR 5nUbUR 5nT"X5nUcgUc [ U5 g[ US5nURU5 SSS5 g![a USpNf=f![a USp Nf=f!,(df  g=f) N rBz--tag +z --tag $\1>w)splitresub ValueErrorstripropenwrite)rwrvfnameoutstrfr|s r$ _flow_magic$make_line_magic.._flow_magics ! 3*IC==vv7tL %**S!,KDzz|  KKME# >  = 6NeS!Q"!# !b ! %% %"!s.2B/CC/ B?>B? CC C#returnc>[5RSSU35 g)Nrzslice --noheader )r run_line_magic)rws r$ histslice"make_line_magic..histslices $$V/@-GHr&)globalsitemsinspect isfunctionstrr _FLOW_LINE_MAGIC__name__)rznamevalrrr|r{s` @@r$make_line_magicrNs%ioo//73E3Ec3J/JX # 6III ",K { ++es !BBrwrcSnUR5n[5nUS;a#SURlSURlgUS;aSURlg[ U5 g)NzUsage: %flow [enable|disable])r+r-TFzdataflow capture enabled)r,r.zdataflow capture disabled)rrrpdataflow_enabledr_r%)rwusagerzs r$rdrdse +E ::r$Could not parse symbols from string z#Could not find symbol metadata for zdefined cell: z; last updated cell: z ; required: z7Symbol {} ({}) is dependent on {} and is a parent of {}nothing)lenr%rastExprparsebodyvalue SyntaxErrorr isinstanceDictListSetTupler resolveparentsis_user_accessiblechildrendefined_cell_num timestampcell_numrequired_timestampis_initializedformatfull_namespace_path) rrnodesymparrchildrsym_extra_infos r$r0r0s rrz*Could not find unique symbol metadata for )rr%rrrrrrrrrrrrrr rrr3)rrrrs r$r4r4s .E :! U CHHcii 388;<BB$388SWWcii@AA U    J 'C { 89I9I9K8L M  sxxz?  3J4D4D4F3G HIsAD &D54D5line_cSnUR5n[U5S:Xd USS:Xa$[5RR 5/nO8USS:Xa#[5R R 5nO [U5 g[5nUHCnUH:nUR(dMUR(aM)URU5 M< ME U(dgSU-$)Nz&Usage: %flow show_waiting [global|all]rglobalallz*No symbol waiting on dependencies for now!z%Symbol(s) waiting on dependencies: %s) rrr global_scopeall_symbols_this_indentationaliasesvaluesr%set is_waiting is_anonymousadd)rrrwsym_sets waiter_setsym_setrs r$r6r6 s 4E ;;=D 4yA~aH, F   < < >0  aE 6>>((* U JC~~~c&6&6&6s# ;6CCr&cJUR5nSn[U5S:wa [U5 gUSR5nUS:XdUR S5(aS[ 5lgUS:XdUR S5(aS [ 5lg[U5 g) Nz,Usage: %flow trace_messages [enable|disable]rrr-r+Tr.r,F)rrr%lowerrortrace_messages_enabled)rrwrsettings r$r7r7!s ;;=D :E 4yA~ U 1gmmoG$',,X66(,% E W// ::(-% U r&rvrestcSnUR5R5nUS:XdUS:waUS:XdUS:XdURS5(a([R[ 5R lgUS:XdURS5(a([R[ 5R lgU[Vs1sHo3RiM sn;a#[U5[ 5R lg[U5 gUS:Xa([R[ 5R lggs snf) Nz#Usage: %flow [hls [strategy]|nohls]r8r9rr-r+r.r,) rrrorEXECUTEDrrpr;NONErr%)rvrrmembers r$rere0s 1E ::<   D e|sg~ 2:)B)B-7-@-@DF   * U]dooi88-7__DF   * <vll< <-7-=DF   * K )3&  =sD=rCr?)nargstypedefaultz--stmtz--stmts store_true)actionz --blackenz--tagz --noheaderc [R[R"U55nUR(agUR nSnUR nUcUc[5R5S- nUb[5RU51nOhUR b[URS5(a,USSn[5R5RU5 [5RU5nUc [S5 g[U5S:XaUb[SU35 gUR (a[5R#U5nO[5R%U5n['[)[5R+U5UR =(d UR,[&UR.(+S95$)Nr$zCell(s) have not yet been runrzNo cell(s) for tag: )blacken format_typeinclude_cell_headers) _SLICE_PARSER parse_argsshlexrhelprFrr exec_counter at_timestampro current_cellmark_as_reactive_for_tagfrom_tagr%rstmtcompute_multi_slice_stmtsmake_multi_slicerrmake_cell_dict_from_closurernoheader)rwr"rF slice_cellsrclosures r$rDrDHsv  # #EKK$5 6D yy ((CK}}H ;w++-1Hw++H56   >>#  ab'C G " ; ;C @g&&s+  ,-$ # [ Q 3? #C5 )*  99050Q0Q1Gg..{;G 33G< 1T\\)-%6    r&rFz8Usage: %flow tag [--remove] [--cell cell_num])rtag_name)rz--removez--cell)rrc [R[R"U55nUR(agUR nUR c[5R5nO#[5RUR 5n[UR5nUR(a[XB1- 5Ul g[XB1-5Ul [5RURU5 gN) _TAG_PARSERrrrrrcellrr at_counterrtagsremovetuple _cells_by_tagr)rwr"rFr cell_tagss r$rFrFws  ! !%++d"3 4D yy --C yyw##%w!!$)),DIII {{)e+,  )e+,  c"&&t, r&rGz(Usage: %flow show_tags [--cell cell_num]c8[R[R"U55nUR(agUR c[ 5R5nO#[ 5RUR 5n[SUR5 g)NzCell has tags:) _SHOW_TAGS_PARSERrrrrrrrrrr)rwr"rs r$rGrGsg  ' ' D(9 :D yy yyw##%w!!$)), TYY' r&cS[RS[RS3n[UR55n[ 5nX#RlU[R:Xa0[5R5HnURS5 M UR5S-Ul URRnUb UR!SUR"SS.5 gg![a [ U5 gf=f) NzUsage: %flow mode [|]FrrhT)rrIsuccess)rNORMALREACTIVErrr%rrprIrcurrent_cells_for_each_id set_readyrl_min_new_ready_cell_counter comm_manager_commsendr)rrrIrzrcomms r$rhrhs!-"6"6!7q9O9O8PPQ RE!%++-0  FE#, M***G557D NN5 !8(-(:(:($set_exec_schedule..s.`N_(~~N_srlivenessr<hybrid) joinrroLIVENESS_BASED DAG_BASEDHYBRID_DAG_LIVENESS_BASEDr%rrprK)rrrJs r$riris%chh.`N_.`&`%aab cE  ##$33   % $..   ( # #$>> U (0DF%r&cUR5R5nS[RS[RS3nUR S5(dUS;a[RnO9UR S5(dUS;a[RnO [ U5 gU[5Rl g)NzUsage: %flow direction [rrany) unorderedbothin)orderedlinear) rrr ANY_ORDERIN_ORDERror%rrprP)rrrPs r$rjrjs KKM   !E "=#:#:";1]=S=S;U;U:VVWX  ((#E*  U *4DF'r&rc$SU;a[R"U5$[5RSR US5nUbU$[ USS9n[U5S:Xa[[U55R$g![a gf=f)N. user_globalF)should_update_usage_infor) pycresolve_tracer ImportErrorr ns_tablegetrrnextiterobj)r tracer_clssymss r$_resolve_tracer_classr8s d{ %%d+ +!]++M:>>tTJ  ! #D5I t9>T #'' '  sB BBcS[5lUH7nUR5 [5RR U5 M9 g![ a MIf=f)NT)rtracer_cleanup_pendingclear_instanceregistered_tracersrr)tracerstracers r$_deregister_tracersr?sQ%)EG"  G & & - -f 5   s#A AAc[U/[5RVs/sH!nURUR:XdMUPM# sn-5 gs snfr)r?rr<r)r6r>s r$_deregister_tracers_forrAsP   '44 4*"5"55 4   s A A cUR5nSn[U5nUc [U5 g[U5 UR 5 [ 5R RSU5 g)Nz:Usage: %flow register_tracer r)rr8r%rAinstancerr<insertrrr6s r$rUrUsX KKME HE&u-J U J' G%%a4r&cUR5nSnUR5S:Xa'[[[ 5R 55 g[ U5nUc [U5 g[U5 g)NzBUsage: %flow deregister_tracer [|all]r) rrr?listrr<r8r%rArEs r$rWrW sW KKME PE {{}D!;!;<=*51   K  +r&cUR5nSn[RRU5(a [ U5nO<[RR U5(a [ U5nO [U5 g[SU5 g)Nz5Usage: %flow register_annotations z#Registered annotations for modules:) rospathisdirr isfiler r%r)rrmoduless r$rtrtsa KKME CE ww}}U07   +E2 U  0':r&)rzr)Srrrfos.pathrIrrr typingrrrrrrpyccolor.IPythonr IPython.core.magicr ipyflow.analysis.symbol_refr ipyflow.annotations.compilerr r ipyflow.configrrrrripyflow.data_model.cellripyflow.data_model.symbolripyflow.experimental.dagripyflow.singletonsrripyflow.slicing.mixinrripyflow.tracing.symbol_resolverripyflow.utils.magic_parserr ipyflow.flowrrrruprintrr%rrrdr0r4r6r7rer add_argumentintrDrrFrrGrhrirjrk BaseTracerr8r?rArUrWrtr&r$rcs   JJ21*,8*>@2) 2 EG38 -s,l # (3-  #(3-@#,DD D. # $  9 93 94 9 G$ :SsDI 8Y|D ;|< 7#CF < =$S$Xc]$N K  #. L9 T:cd$ Axc4@ C D    ( 1S 1T 1 0c 0d 0 5# 5$ 5cnn1E(F" 53 54 5 ,S ,T , ; ; ;r&