!ɀizdZddlZddlZddlZddlZddlmZmZddlmZdZ dZ ee jZ e dz Zejd ej ej"d ej$ed z ej&g ej(eZd efdZded efdZd efdZdZedk(rej:eyy)a Daily scheduler for content pipeline. Runs at a random time between 08:00 and 19:00. Usage: - Schedule this script to run early morning via cron (e.g., 00:05) - It will sleep until a random time in the configured window - Then execute the pipeline Cron entry: 5 0 * * * cd /var/www/html/content-pipeline && ./venv/bin/python daily_scheduler.py >> logs/scheduler.log 2>&1 N)datetime timedelta)PathlogsT)exist_okz)%(asctime)s - %(levelname)s - %(message)sz scheduler.log)levelformathandlersreturnctj}|jdddd}tdz}tdz}t j ||dz }|t|z}|S)z@Generate a random datetime between start and end hour for today.r)hourminutesecond microsecond<)minutes)rnowreplacePUBLISH_WINDOW_START_HOURPUBLISH_WINDOW_END_HOURrandomrandintr)rtoday start_minutes end_minutes random_minute publish_times 1/var/www/html/content-pipeline/daily_scheduler.pyget_random_publish_timer"+sf ,,.C KKQqK BE.2M)B.KNN=+/BM9];;L  target_timec "tj}||k\r)tjd|j ddy||z j }t t|d\}}t |d\}}tjd|d|d |j dd }|d kDr_t||}tj|||z}|d kDr.tt| } tjd | d|d kDr_y)ze Sleep until the target time. Returns True if we slept, False if target time has passed. z Target time z%H:%Mz has passed, running immediatelyFirz Sleeping for zh zm until i,r)secondszStill waiting... z remainingT) rrloggerinfostrftime total_secondsdivmodintmintimesleeprdebug) r$r sleep_secondshours remainderrr& chunk_sizesleep_duration remainings r! sleep_untilr7>s ,,.C k l;#7#7#@"AAabc 3&557Mc-0$7E9i,GW KK-wb +:N:Nw:W9XYZJ ! Z7 >"' 1 !#m*<=I LL,YKzB C !  r#ctjd tjj dt t ddlm}|S#t$r"}tjd|Yd}~yd}~wwxYw)zExecute the content pipeline.zStarting content pipeliner)mainzPipeline execution failed: Nr) r'r(syspathinsertstr PROJECT_DIR cron_runnerr9 Exception exception) cron_maines r! run_pipelinerD]s_ KK+,  3{+,1{ 6qc:;s9A A<A77A<c$tjdtjdtjdtddtddtjdt }tjd|j dt d z }t|d 5}|j|jd d d d t|t}tjd ||S#1swY8xYw)zMain scheduler entry point.z<============================================================zDaily Content Scheduler StartedzPublish window: 02dz:00 - z:00zSelected publish time: z%Y-%m-%d %H:%Mzscheduled_time.txtw Nz#Scheduler finished with exit code: ) r'r(rrr"r)LOG_DIRopenwrite isoformatr7rD)r schedule_filefresults r!r9r9ms KK KK12 KK"#? M11s ,#DD__main__)__doc__loggingrr:r.rrpathlibrrr__file__parentr>rImkdir basicConfigINFO FileHandler StreamHandler getLogger__name__r'r"boolr7r,rDr9exitr#r!r`s  (8n##   t  ,, 6Go56   8 $&X$> c  4 z CHHTVr#