3j SrSSKJrJrJr SSKJr SSKJr SSKrSSK J r SSK J r S\ S \ S \4S jrS \ 4S jrS \ 4S jrSS\ S\/S4S\S \/S44SjjrSS\S \4Sjjrg)uXÜtemezett feladatok segédei: EGYSZERI FUTÁS biztosítása több gunicorn worker mellett. TÖRTÉNET / MIÉRT KÉSZÜLT (2026-10-04, e-mail rendszer B szelet) Az éles szerver 3 gunicorn workerrel fut. A main.py modulszinten indítja az APScheduler-t, ezért MINDEN worker elindítja a saját ütemezőjét - a napi riport (06:00) és a korlátozott gépek ellenőrzése (06:05) így akár 3-szor is lefuthatott, és ugyanaz a levél 3-szor ment ki. HOGYAN OLDJUK MEG? Minden futás előtt a feladat megpróbál beszúrni egy (feladat, kulcs) párt az `utemezett_futasok` táblába (models.UtemezettFutas). A pár egyedi, ezért az adatbázis pontosan EGY workernek engedi a beszúrást - a többi IntegrityError-t kap és kihagyja a futást. - napi feladatnál a kulcs a helyi dátum ("2026-10-05"), - percenkénti feladatnál az UTC perc ("2026-10-05T04:01"). Előnyök a fájlzárral szemben: működik Windows-on (fejlesztés) és Linuxon is, nem akad meg, ha egy worker összeomlik, és nincs szükség külső szolgáltatásra (Redis). MIT NE TEGYÉL? - Ne hívd közvetlenül a védett feladatot az ütemezőből: használd a `vedett()` burkolót. - A kézi indítás (pl. /teszt-riport) NEM megy át a védelmen - az szándékosan azonnal fut. Részletes leírás: docs/EMAIL_RENDSZER.md )datetime timedeltatimezone)Callable)IntegrityErrorN) SessionLocal)HELYI_TZfeladatkulcsreturnc [5nUR[R"XS95 UR 5 UR 5 g![ a# UR5 UR 5 g[aTnUR5 [SUSUS[U5RSU35 SnAUR 5 gSnAff=f!UR 5 f=f) u"Igaz, ha EZ a folyamat nyerte meg a (feladat, kulcs) futást, és tehát le kell futtatnia. Hamis, ha egy másik folyamat már lefoglalta, VAGY ha az adatbázis hibát adott (utóbbi esetben inkább kihagyjuk a futást, mintsem hogy többszörösen fusson - a hibát a konzolra naplózzuk).)r r TFu%❌ Ütemezett futás-védelem hiba (/z): : N) raddmodelsUtemezettFutascommitcloserrollback Exceptionprinttype__name__)r r dbes !/var/www/website/utemezo_utils.pyegyszeri_futasr!s B  v$$WBC         5gYawc$q'JZJZI[[]^_]`ab    s53AC+C= C:CCCCC/cT[R"[5RS5$)Nz%Y-%m-%d)rnowr strftimer _napi_kulcsr#5s << ! * *: 66r"ch[R"[R5R S5$)Nz%Y-%m-%dT%H:%M)rrrutcr r!r"r _perc_kulcsr&9s# << % . ./? @@r"fuggveny percenkentic0^^^UUU4SjnST3UlU$)uBecsomagolja az ütemezett függvényt: csak akkor hívja meg, ha ez a folyamat nyerte a futást. `percenkenti=True` esetén a kulcs a perc, különben a nap.cn>T(a [5O [5n[TU5(aT"5 gg)N)r&r#r)r r r'r(s r_burkolovedett.._burkoloCs'!, +- '5 ) ) J *r"vedett_)r)r r'r(r+s``` rvedettr.@s"'+H Or" megtartas_napc`[5n[R"[R5R SS9[ US9- nUR[R5R[RRU:5R5nUR5 UUR5 $![aNnUR!5 [#S[%U5R&SU35 SnAUR5 gSnAff=f!UR5 f=f)uTörli a régi futás-bejegyzéseket (naponta egyszer hívjuk az email_sor.takaritas-ból). Visszatérés: a törölt sorok száma.N)tzinfo)daysu<❌ Ütemezett futás-bejegyzések takarítása sikertelen: rr)rrrrr%replacerqueryrrfilter futott_atdeleterrrrrrr)r/rhatartoroltrs r takaritasr:Ks B  X\\*22$2?)Q^B__&//0778M8M8W8WZ_8_`ggi     LTRSWM]M]L^^`ab`cde    s*B#C D 4D>DDDD-)F))__doc__rrrtypingrsqlalchemy.excrrdatabaser templates_envr strboolrr#r&r.intr:r!r"rrDs,32) !"C(7S7ASAC8BH#5DU]^`bf^fUgSr"