esj ddlZejjddddlmZmZmZmZmZddl m Z ddl m Z ddl mZddlmZddlmZdd lmZdd lmZed d g Zej1dddeddeddddeefdedede fdZej9ddded d!eefd"ede fd#Zej9d$d%d&eefde fd'Zy)(Nz/var/www/html/metafoliadorv2) APIRouterDepends HTTPExceptionQueryPath)Session)desc)get_db) SyncProgress) AlfrescoSite)AlfrescoFolder)isoz /api/v1/jobsjobs)prefixtagszListar trabajos en colauXLista los trabajos de sincronización registrados en SyncProgress. Filtrable por estado.)summary descriptionzAFiltrar por estado: pending, running, completed, error, cancelled)r2uMáximo de trabajos a retornar)rgelestatuslimitdbcK|jtjtjdkD}|r"|jtj|k(}|j t tjj|j}g}|D]^}d}d}|jr[|jtjtj|jk(j} | r | j}|jr[|jtjtj|jk(j} | r | j}|j!|j|j||j||j"|j|j$|j&t)|jt)|j*d a|Sw)Nrr) idsite_id site_name folder_id folder_nametask_idrprogressmessage created_at updated_at)queryr filterrrorder_byr r&rallr rfirstnamer!r appendr#r$r%rr') rrrqrresultjr r"sitefolders 3/var/www/html/metafoliadorv2/app/api/routes/jobs.py list_jobsr5s~ %%l&:&:Q&>?A HH\((F2 3 ::d<223 4 : :5 A E E GD F    9988L)00AII1MNTTVD II ;;XXn-44^5F5F!++5UV\\^F$kk  $$yy"&yyhh yyall+all+   2 MsHH z/{job_id}/cancelzCancelar trabajouLRevoca una tarea Celery pendiente o en ejecución y la marca como cancelada..zID del trabajo a cancelarjob_idcK|jtjtj|k(j }|s t dd|j dvr t ddddlm}dd l m }|jr$||j| jd d |_d|_ |jd ddSw)NizTrabajo no encontrado) status_codedetail)pendingrunningiz:Solo se pueden cancelar trabajos pendientes o en ejecucionr) AsyncResult celery_app)appT) terminate cancelledzCancelado por el usuariozTrabajo canceladookr%)r(r r)rr,rr celery.resultr< app.workerr>r#revoker%commit)r6rjobr<r>s r4 cancel_jobrI5s ((< ' ' 6(A B H H JC 4KLL zz//4pqq)% {{CKKZ077$7GCJ,CKIIK#6 77sC Cz/purgez Limpiar colauaPurga la cola de Celery y elimina todos los registros de SyncProgress pendientes o en ejecución.c&Kddlm} |jj|j t j t jjddgj|jdddS#YjxYww)Nrr=r:r;Tz Cola limpiarB) rEr>controlpurger(r r)rin_deleterG)rr>s r4 purge_jobsrOIsv%   " HH\!!I 67 fhIIK= 11  sBB A&B B B)syspathinsertfastapirrrrrsqlalchemy.ormr sqlalchemyr app.models.databaser app.models.sync_progressr app.models.alfresco_siter app.models.alfresco_folderr app.services.timezonerroutergetstrintr5postrIrOr4rbse 12BB"&115% .x 8B1@Z["':}"~NSTVdDIJORNScjkqcr C HK Y` [ F );JXY#'9T#Uelmset8S8[b8Y8&X~<_`#*6?22`2ra