
    Rh[                         d dl Z d dlmZ d dlmZmZmZ d dlmZ d dl	m
Z d dlmZ d dlmZ  e j                   d      Z edd	d	
      Zej&                  dededefd       Zy)    N)Celery)ListDictOptional)StormRunner)Courses)SessionAPP_URLtaskszredis://localhost:6379/0)brokerbackendtopic	course_idreturnc                 d   t        j                         }	 t        |       }|j                         }|j	                  t
              j                  t
        j                  |k(        j                         }t         d|  }|r0||_
        d|_        |j                          |j                  |       nd| d|j                          S 	 |j                          y# t        $ r8}|j!                          dt#        |       cY d }~|j                          S d }~ww xY w# |j                          w xY w)Nz/download-imscc?topic=ReadyzCourse with Course ID z not found.zError processing Course: zCourse processed successfully.)dbaseSessionLocalr   process_articlequeryr   filterr   firstr
   course_imscc_urlstatuscommitrefreshclose	Exceptionrollbackstr)r   r   dbrunnerresultcoursedownload_linkes           (/var/www/html/sandstorm/celery_worker.pyprocess_article_celeryr(      s   
 $$&BU# '')'"))'*;*;y*HIOOQ")#9%A&3F##FMIIKJJv+I;kB 	
  	
+  4
*3q6(33 	
4
 	
s0   B C 	D"D?D D DD D/)osceleryr   typingr   r   r   dependencies.StormRunnerr   db_config.databasedatabaser   db_config.modelsr   sqlalchemy.ormr	   getenvr
   
celery_apptaskr    r(        r'   <module>r6      sr    	  ' ' 0 " $ "
"))I
%&
 ,,, 	, ,r5   