+ #jx#Rt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t ]PP^]!] !]4P!4P"44^RIHtHtHtHtHtHtHtHt^RIHtHtHt^RIHtRR lt R R lt!RR R llt"]#R8Xd]PH!]"!44R#R#)u run_batch.py — Run a workflow many times, varying parameters per run. Two modes: 1. --count N --randomize-seed Submit N runs, each with a fresh random seed. Use for quick variations. 2. --sweep '{"seed": [1,2,3], "steps": [20,30]}' Cartesian product of values. With cloud subscription, runs in parallel up to your tier's concurrent-job limit. Both modes write each run's outputs into output-dir/run_NNN/. Examples: python3 run_batch.py --workflow flux_dev.json --args '{"prompt": "a cat"}' --count 8 --randomize-seed --output-dir ./outputs/cat-batch python3 run_batch.py --workflow sdxl.json --args '{"prompt": "abstract"}' --sweep '{"seed": [1,2,3], "steps": [20, 40]}' --output-dir ./outputs/sweep ) annotationsN)ThreadPoolExecutor as_completed)Path)DEFAULT_LOCAL_HOST ENV_API_KEY coerce_seed emit_jsonloglooks_like_video_workflowresolve_api_keyunwrap_workflow) ComfyRunnerdownload_outputs inject_params)extract_schemac ,V^8dQhRRRRRRRRRR /#) sweepdict base_argscountintrandomize_seedboolreturnz list[dict])formats"c/opt/hermes-venv/lib/python3.14/site-packages/../../../skills/creative/comfyui/scripts/run_batch.py __annotate__r.s0c4T^cV'd\VP44pVUu.uF0p\W,\4'd W,MW,.NK2 pp.p\P!V!F7p\ V4p \ WH4F wrZWV&K VPV 4K9 V#.p\V4F5p \ V4p V'd\R4V R&VPV 4K7 V#uupi)z+Generate a list of args dicts for each run.Nseed) listkeys isinstance itertoolsproductrzipappendranger) rrrrr$kvaluesrunscomboarv_s &&&& r expand_sweepr2.s EJJL!RVWRVQj488%(uxjHRVW&&/EiBD(1) KKO 0  D 5\ )_ $T*BvJ B  KXs6C9c8V^8dQhRRRRRRRRRRR R R R R R/#)rrunnerrworkflowrschemaargs output_dirrtimeoutrwsrrr)rs"rrrEsN%% %#'%15%=A%%"%%+/% %r c T\WV4wrxVPV4p RV 9dRRRRRV PR4RV/#V PR4p V 'g RRRRR V RV/#V PR 4'dRRRR R V R ,RV/#V'dVPWR 7p MVP WR 7p V R,R 8wd!RV R,RV RV PR4RV/#V PR4;'gVP V 4p \ W VRR7p RR RV RVRV RV/#) _http_errorstatuserrorzsubmission HTTP errordetailsbodyr7 prompt_idz no prompt_idresponse node_errorszvalidation failed)r9successdataoutputsF)preserve_subfolderwarnings)rsubmitget monitor_ws poll_status get_outputsr)r4r5r6r7r8r9r:wfrHsubpidresultrF downloadeds&&&&$$$ r execute_onerSEsb!48LB -- C'7,C3776?FD: : ''+ C '7NJVUYZZ ww}'7,?s=164A A ""3"8##C#9 h9$ fX&  vzz&) D   jj#>>v'9'9#'>G!&:RWXJ)S:H  r c V^8dQhRRRR/#)rargvzlist[str] | Nonerrr)rs"rrrmsB%B%B%3B%r c0\P!RR7pVPRRR7VPRRRR7VPR \^R R 7VPR R RR7VPRRRR7VPR\R7VPRR\ 2R7VPR4VPR\^RR 7VPRRR7VPR\^R7VPRRR 7VPR!RR"R7VP V4pVP^8:d"VP'g\R#R$/4^#VPP4'd!\P!VP4M/pVPP4'd!\P!VP4M/pV'd\V\4'g\R#R%/4^#VP!4UUu.uF1wrV\V\"4'gK\%V4^8XgK/VNK3 pppV'd\R#R&V 2/4^#VP'gVP&'d \)R'4\+VP,4P/4pVP14'g\R#R(VP, 2/4^#VP34;_uu_4p \5\P6!V 44p R)R)R)4\?X 4p \AYCTPTP&4p \)R*\%T 4 R+24\CTPD4p\GTPHYPJR,7pTPM4wppT'g\R#R-R.TR/TPH/4^#TPNpT^8:d\QT 4'dR0MR1p\+TPR4P/4pTPURRR27.p^pTPV^8EdH\YTPVR37;_uu_4p/p\[T 4F>wppTR4TR5 2, pTP]\^YT TTTTP`R67pTTT&K@ \cT4FpTT,pTPe4pTTR9&TPiT4TR7,R:8wdVT^, p\)R;T R4 24TPl'g\)R?4M1K\)R;T R@\%TPkRA.44 RB24K R)R)R)4M\[T 4FwppTR4TR5 2, p\_YT TTTTP`R67pTTR9&TPiT4TR7,R:8wdVT^, p\)R;T R4 24TPl'g\)R?4M1K\)R;T R@\%TPkRA.44 RB24K TPoRCRD7\R7T^8XdR:MRERF\%T 4RG\qRHT44RITRJ\=T4RKT/4T^8Xd^#^#uuppi +'giEL;i \8\P:3d"p \R#\=T 4/4R)p ? ^#R)p ? ii;i \fd$p R7R#R#\=T 4R8T T,/pR)p ? ELtR)p ? ii;i +'giL;i)Lz5Submit a workflow many times with varying parameters.) descriptionz --workflowT)requiredz--argsz{}zBase parameters JSON)defaulthelpz--countz*Number of runs (use with --randomize-seed))typerYrZz--sweepu[JSON dict of param→list of values. Cartesian product. e.g. '{"seed":[1,2,3],"cfg":[5,8]}'z--randomize-seed store_truez"In --count mode, vary seed per run)actionrZz--host)rYz --api-keyzor set $)rZz --partner-keyz --parallelzMConcurrent submissions (cloud: up to your tier limit). Default 1 (sequential)z --output-dirz./outputs/batchz --timeout)r[rYz--ws)r^z--continue-on-errorz%Don't stop the batch when a run failsr>z$Specify --count N or --sweep '{...}'z/--sweep must be a JSON object {param: [values]}z+--sweep parameters have empty value lists: zI--sweep set; ignoring --count / --randomize-seed (sweep defines the runs)zWorkflow not found: NzPlanned z run(s))hostapi_key partner_keyzCannot reach serverr?r_ii,)parentsexist_ok) max_workersrun_04d)r8r9r:r=r7indexrDz run u → z: ?z- --continue-on-error not set; aborting batchu → success: rFz filesc&VPR^4#)rg)rJ)xs&rmain..squuWa0r )keypartialtotal completedc3D"TFqR,R8XgK^xK R#5i)r=rDNr).0rs& r main..sHGq{i/GGs  failedr8results)9argparseArgumentParser add_argumentrrr parse_argsrrr r7stripjsonloadsr%ritemsr#lenrr rr5 expanduserexistsopenr load ValueErrorJSONDecodeErrorstrrr2r r`rr_ra check_serverr9r r8mkdirparallelr enumeraterIrSr:rrQ Exceptionr)rJcontinue_on_errorsortsum)rUpr7rrr+r0emptywf_pathfr5er6r-r`r4okinfor9base_dirrwfailuresex future_to_idxir/run_dirfutrss& rmainrmsK ANN<$N/NN8T0FNGNN93DFNN9b@ANN%l<>NN8%7N8NN;x }%=N>NN?#NN+>  724==/BCD \\^^q&tyy|4H H %F $**d6I6I JD(3t9+W%&dll+G diiFVFV WF""$HB 719dFDIIVWllG!|28<<##DOO$//1H NN4$N/GH }}q DMM : :bM"42"tAc7^3ii62&DGG &' c" )$M2!#&N A' q!X;)+MH&58 Rgc8J7KLM111KL2&>#aeeIr6J2K1LFST3; :4t_EAr4#w/GFfb&-w477LAAgJ NN1 {i'A fQCuQx[MAEE'#4F3GHI---GH.fQC~c!%% 22F.G-HOP% LL0L1 x1}))TSHGHH(c(m7 A 1$1$yU^^ ,, -7CF#$P!N!7GSVVT!WMAN; :s4[; [;%[; \% \\A'^9] B(^ \ \\]0]  ] ^ ]= 7^=^ ^ ^ __main__)N)%__doc__ __future__rrxr&r}sysconcurrent.futuresrrpathlibrpathinsertr__file__resolveparent_commonrrrr r r r r run_workflowrrrrr2rSr__name__exitrr rrs0# ?3tH~--/6678*.%PB%J zHHTVr