j fdZddlZddlZddlZddlZddlZej jej jej je Z e e ddZ dZ dZdZe dd Zesej"dej%d ej%d xsicZZed ed dededdeedk(re ded ddej%dr deedgngZej.ej0e dedgeddZeej4ddej6ddzej8dk(r&e ded deeej"dej8r&e ded deeej"dej4j;j=dZdedZ ned k(rej.ej0e dd!edeed"gddZeej4d#dej6d#dzej8r&e ded deeej"dej4j;j=dZded$Z n#e ded dd%eej"de ded de ej.e d&gddZ!ee!j4d'de!j6d'dze!j8r$e ded dded(ej"dedjEd)d*Z#edjEd)djEd+Z$d,d)jKe$d)e#d-gedk(r d.e#d/egngzZ&ej.d0d1e d2d3ge&d4ej.d0d1e d5d6edk(rd7nd8dedd9ed3ge&d4e ded d:ded;ed k(rdey)?a.Cron (every minute, under its own flock): take the next QUICK job (lighter copy, use-in-games) from the spike API store on prod, run tools/lighter.py, publish, report back. Astra re-runs have their own lane (tools/rerun_worker.py), so a quick job never waits 40 minutes behind one. Log: jobs/worker.logNz/jobs/worker.logac tjddddjd|Dzgddd}tj|j xsd S) Nsshprodz.cd /home/forge/fal-feedback && python3 cli.py  c3(K|] }d|d yw)'N).0rs tools/lighter_worker.py zprod.. sd|rsghijhkklemd|sT<)capture_outputtexttimeoutz{}) subprocessrunjoinjsonloadsstdout)argsouts r rr sR ..%)Y\_\d\dd|w{d|\|)|}(,4 EC ::cjj(D ))ctjtjdtj|zdztj y)Nz%Y-%m-%dT%H:%M:%SZ  )LOGwritetimestrftimegmtimeflush)ts r logr$s2IIdmm14;;=AAELMsyy{rc|jxsdjjxsdgdddjddS)Nfailedi,r r)stderrstrip splitlinesreplace)rs r lastr.sD XX^ " " $ / / 1 ?hZ DTc J R RSVX[ \\rnextquickkindparamsz quick job idrassetlighterupdaterunningz>making lighter tries and checking them on the GPU (1 to 3 min)targetz--targetz/tools/lighter.pyT)rri$leanr'r(vz lighter copy made; publishingactivatez --activateversioni z goes to games; publishingzunknown job kind z/tools/publish_all.shiz) saved but publishing failed (worker.log)/.zcards/z index.jsonz jobs/lighter-z-vgitz-Caddz--)rcommitz-qmz lighter copyz use in gamesz vdonez publishedz (in games now)z as a draftz done v)'__doc__rosrsysrpathdirnameabspath__file__ROOTopenrrr$r.jexitgetr1prmstrrr executabler-rr) returncoder*r+vermsgpsplitslugclsrpathsr rr r\s?'&& wwrwwrwwx'@AB dV# $c** []  CHHQK EE&M155?0b cj4 4&!G*Qse4591T7I'gh/2wwx/@JCM* +bD 4&0A(BAgJVQUVgkrvwA188EF++,||q XqwQ0(#((1+|| Xqw$q'2HCHHQK ((..  % % ' +C cU0 1C Z 4&0A(BLRST[R\^abefobp^qrDHOS TA!((45/)*|| Xqw$q'2HCHHQK ((..  % % ' +C cU, -C1T7H(9$&@A8388A;Xqw 3'JNNtf123DtTAHHUVqxx''(<<1T7H#.W&XY[c[^[c[cde[fzQjsA$$S) #((3-$ (,7^bfo^omD6QSTWSX