tĀidZddlZddlZddlZddlZddlmZddlmZejjde ee jddl mZee jdz Zej!dee jd z Zee jjdz d z Zd Zd efd ZdZde fdZdefdZdZedk(rej8eyy)zV Cron wrapper for content pipeline. Handles locking, logging, and error notification. N)datetime)Path) run_pipelinelogsTexist_okz.pipeline.lockz error.logctdtjjddz }t j |}|j tj|jt jdt j}|j tj|jt jdt j}|j tj|j||j|t jtS)z%Configure logging for cron execution. pipeline_z%Y-%m-%dz.logz4%(asctime)s - %(name)s - %(levelname)s - %(message)sz%(levelname)s: %(message)s)LOG_DIRrnowstrftimelogging FileHandlersetLevelDEBUG setFormatter Formatter StreamHandlerINFO getLogger addHandler__name__)log_file file_handlerconsole_handler root_loggers -/var/www/html/content-pipeline/cron_runner.py setup_loggingrs9X\\^%<%A AA A A;A66A;c *t}|jd|jd|jdts|jdy t }t j j|j|j|j|j|j|j|j|jd }t!||jr;|jd|j t#|jdy|jxs|jxsd}|jd ||jrt%d | t#|jdy #t&$rM}|j)d t%d t+|Yd }~t#|jdy d }~wwxYw#t#|jdwxYw)zMain cron entry point.z<============================================================z$Content Pipeline Cron Runner Startedz!Pipeline already running, exitingr) rEsuccesstopic_id article_id wp_post_idpost_urlerrorskipped_reasonstatsz!Pipeline completed successfully: z%Content Pipeline Cron Runner Finishedz Unknown errorzPipeline failed: zUnhandled exception in pipelinezUnhandled exception: N)rinfor0warningrrr r+rRrSrTrUrVrWrXrYrPr5rGr@ exceptionr*)loggerrH run_result error_msgrFs rmainra_s _F KK KK67 KK >:;&="113~~ ++ ++\\$33\\    # >> KK;FOO;LM N"  ;pipelinerr r?r$r=rboolr0r5rGdictrPrarexitr4rrrls   3tH~,,-.! x.  & ( t  N ! !$4 4 >((//&8;F'6 d  LSLBDB2=j z CHHTVr