jSrSSKrSSKJrJr SSKJr SSKJr SSKJ r SSK J r SSK J r SS KJrJrJr SS KJrJrJrJr \R."\5rSS jrS rS rSrSSjrg)zThe scheduled-post worker: publishes due posts and records the outcome (ADR-005). Run by the dedicated scheduler container: python -m app.scheduler N)datetimetimezone)db)ensure_fresh_token) ScheduledPost)ValidationError)validate_post_fields)VIDEO_EXTENSIONSremove_quietly store_upload)TikTokAPIErrorinit_video_pullpublish_video_filewait_for_publishc SSKJn [U5nU"URS55nU(d [ S5eSnUS(a[ USU[ US9nURn[URUSUS S :XaUS OSUS UUS UR[R5RSS 9[RS9n [R R#U 5 [R R%5 [&R)SU RUR+5U R,5 U $)zCreate a pending scheduled post from form/JSON fields plus an optional video file; the file is stored under MEDIA_FOLDER until the scheduler publishes it. Raises ValidationError.rparse_scheduled_time scheduled_atz-scheduled_at is required for a scheduled postN video_file) max_bytestitlemodedirect privacy_level video_urltzinfo) account_idrrr video_pathrrstatusz'scheduled.create ok id=%s at=%s mode=%s)app.services.postsrr getrr r pathrid astimezonerutcreplaceSTATUS_PENDINGrsessionaddcommitloginfo isoformatr) accountdata media_folderupload_max_bytesrfieldsrrstoredposts HF:\Solutions\Thinkera\Publishers\TikTokManager\app\services\scheduled.pycreate_scheduled_postr7s8 !$ 'F'(@AL MNNJ lf\2LBR^no[[ ::Wo1781Kf_-QU F^%!,,X\\:BB$BO++ DJJNN4JJHH 6AWAWAY[_[d[de KcSSKJn U"U5nU(d [S5eUR[R 5R SS9Ul[RUl SUl [RR5 U$)zIMove a scheduled post to a new time and put it back in the pending queue.rrzscheduled_at is requiredNr)r!rrr%rr&r'rrr(r errorrr)r+)r5scheduled_at_valuerrs r6reschedule_postr<2sm7'(:;L 899$// =EETERD..DKDJJJ Kr8cUR(a[UR5 [RR U5 [RR 5 g)zEDelete a scheduled post row and its stored media file (when present).N)rr rr)deleter+r5s r6delete_scheduled_postr@@s7 t'JJdJJr8cz[RUlSUl[R R 5 U$)zPut a failed post back in the pending queue with its original time (already in the past, so the scheduler publishes it on the next tick).N)rr(r r:rr)r+r?s r6 retry_postrBHs- ..DKDJJJ Kr8c U=(d$ [R"[R5nUR(aUR SS9OUn[ RR[ RS9R[ RU:*5R[ R5R5nUGHn[ RUl[ R"R%5 ['UR(5nUR*(a5[-XCR*UR.UR0UR2S9nO4[5XCR6UR.UR0UR2S9n[9XES5nUSS:Xa[ R:UlSUlO[ R>UlSUlUSUl URCS 5Ul"UR[ R>:Xa&UR*(a[GUR*5 [HRKS URLUR5 [ R"R%5 GM [WU5$![Na[n[ R:UlURPUl[HR=S URLURR5 SnANSnAf[Ta> [ R:UlS Ul[HR=S URLSS9 Nf=f)zPublish every pending post whose time has come; marks each row published or failed with a safe error message. Returns the number of due posts processed. `scheduled_at` is stored as naive UTC, so the comparison uses naive UTC too.Nr)r )rrr publish_idpublish_statusFAILEDz.TikTok rejected the video while processing it.video_idz!scheduled.publish id=%s status=%sz&scheduled.publish failed id=%s code=%sz(Publishing failed; check the server log.zscheduled.publish failed id=%sT)exc_info),rnowrr&rr'rquery filter_byr(filterrorder_byallSTATUS_PUBLISHINGr rr)r+rr/rrrrrrrr STATUS_FAILEDr:STATUS_PUBLISHEDrDr"rGr r,r-r$r messagecode Exceptionlen)rI now_naiveduer5tokenresultr es r6 run_due_postsr[QsQ  +hll+C,/JJ 4 (CI    ' '}/K/K ' L S S""i/ h}))*335#55   P&t||4E+??**D4F4FTYY )>>**D4F4FTYY&eL-ABF&'83+99 M +<< ! $\2DO"JJz2DM{{m<<<t/ HH8$''4;; O GH s8O Q'55DKDJ II> P P P'55DKCDJ II6$I O Ps!E.J M&AK<rgsV''$/3OO`` !> .r8