Lista de dags

De Plataforma COA Crowd
Saltar a: navegación, buscar

DAGS

coa_task_error_recovery

Status en el que toma la tarea: ERROR_REINTENTAR
Status en el que sale la tarea: RESOLVIENDO

Tarea que trabaja el dag: Vericuentas desde SIAM
Funcionalidad del DAG: Este dag obtiene todas las tareas de Vericuenta que entran por Siam, a las que no se les pudo obtener el cep al primer intento y quedan con estatus ERROR_REINTENTAR, lo que hace el DAG es hacer los reintentos cada cierto tiempo, para la obtención del documento CEP durante un tiempo determinado (1 hora, 2 horas, etc), una vez que haya obtenido el cep, pasa la tarea a estatus RESOLVIENDO para que se publique una Vericuenta de manera normal. En caso de que en ese tiempo no haya encontrado el cep, lo que hace, es transformar esa tarea en una Vericuenta Manual, o un Veribanco, dependiendo del banco receptor que viene en la solicitud.

coa_task_result_sender

Status en el que toma la tarea: FINALIZADA_NO_CALLBACK
Status en el que sale la tarea: ENVIADA_NO_CALLBACK

Tarea que trabaja el dag: Vericuentas desde SIAM
Funcionalidad del DAG: Este dag busca las tareas de Vericuenta SIAM (Con todas sus variables como: Vericuenta, Veribanco, Vericuenta Manual, Paquete de Disposición) que ya estén resueltas y con el status de FINALIZADA_NO_CALLBACK, lo que hace, es mandar la respuesta hacia la base de datos de SIAM, es un dag especial, ya que la respuesta no se manda por algun Callback, si no que hace un update a una base de datos.

coa_task_sensor

Status en el que toma la tarea: N/A
Status en el que sale la tarea: ERROR REINTENTAR / RESOLVIENDO

Tarea que trabaja el dag: Vericuentas desde SIAM
Funcionalidad del DAG: Este dag busca las tareas de Vericuenta SIAM (Con todas sus variables como: Vericuenta, Veribanco, Vericuenta Manual, Paquete de Disposición) que se encuentren en la base de datos de SIAM con un estatus de "NEW", lo que hace este dag, básicamente es la ingesta de tarea, ya que se trae las tareas de SIAM Crowd, en este mismo DAG se hace la petición del documento CEP de las tareas de Vericuenta, en el caso de que lo obtenga en la primera vez, pasa la tarea a RESOLVIENDO, en caso de que no pueda obtener el cep, pone la tarea en el status de ERROR_REINTENTAR para que lo pueda obtener el dag de coa_task_error_recovery.

domi_result_sender

Status en el que toma la tarea: FINALIZADA_MAQUINA_ESTADOS
Status en el que sale la tarea: ENVIADA_NO_CALLBACKver

Tarea que trabaja el dag: Veridomi
Funcionalidad del DAG: Este dag busca las tareas de Veridomi que ya estén resueltas y con el status de FINALIZADA_MAQUINA_ESTADOS, lo que hace, es mandar la respuesta de regreso, y al mandarla, le pone el status como "ENVIADA_NO_CALLBACK" que sería el ultimo status de la tarea. 

scheduler_maintenance

Status en el que toma la tarea: PUBLICADA
Status en el que sale la tarea: N/A

Tarea que trabaja el dag: Cualquier SEGMENTO de tarea
Funcionalidad del DAG: Este dag obtiene el Deadline de la sesion del usuario, para saber la información de sesión, concretamente si el usuario tiene una sesión abierta, este dag corre cada 15 minutos, por lo que cada 15 minutos busca en la tala de workers, los operadores cuya sesion deadline haya caducado (que sea menor la hora a la actual). En caso de que haya operadores con la sesion caducadada y este tenga aun asignada una tarea en redis, se le desasignará de manera automática para que así, otro operador pueda darle resolución a esa tarea, y no se quede esperando.

send_callback

Status en el que toma la tarea: FINALIZADA
Status en el que sale la tarea: ENVIADA

Tarea que trabaja el dag: Todas las tareas que la respuesta se tenga que mandar mediante callback
Funcionalidad del DAG: Este dag busca las tareas que ya estén resueltas y con el status de FINALIZADA, lo que hace, es mandar la respuesta hacia el callback que se le haya configurado, independiente mente de si entrar por inbound, kafka, etc. Mientras tenga callback, la tarea pasa por este dag, y termina con un status "ENVIADA" el cual es el ultimo status el cual puede tener una tarea.

suspended_task_publisher

Status en el que toma la tarea: PUBLICADA
Status en el que sale la tarea: PUBLICADA

Tarea que trabaja el dag: Cualquier microtarea que se pueda suspender
Funcionalidad del DAG: Este dag busca entre todas las microtareas, las tareas cuya resolución tenga el campo de "sleepTime" el cual significa, que por alguna razón, esa tarea se suspendió, en caso de que una tarea tenga ese campo y adicionalmente ya haya pasado la hora (que el tiempo actual, sea mayor al tiempo que se visualiza en el campo), este dag publica la tarea, ya sea esa misma, o alguna variante de esta, dependiendo la configuración en el motor de tareas.

task_builder

Status en el que toma la tarea: PUBLICADA
Status en el que sale la tarea: FINALIZADA - PUBLICADA

Tarea que trabaja el dag: Todas las tareas ya sea crowd, findepmovil, etc.
Funcionalidad del DAG: Este dag es uno de los mas importantes, ya que lo utiliza pracricamente todas las tareas, este dag tiene multiples funcionalidades que se hacen al momento de terminar una tarea, por ejemplo, en las tareas secuenciales. Es el dag que se encarga de buscar que se haya resuelto cada uno de los segmentos que componen la tarea, para así, dependiendo de la configuración en el motor de tareas, sepa si crear una tarea secuencial o bien, terminar la tarea. Por este dag tambien pasa el modelo de calidad, ya que también evalúa las respuestas de los segmentos de calidad, así, de esta manera saber si se tiene que hacer la tarea de supervisor o simplemente seguir el flujo.

task_error_recovery_vericuenta

Status en el que toma la tarea: ERROR_REINTENTAR
Status en el que sale la tarea: RESOLVIENDO

Tarea que trabaja el dag: Vericuentas
Funcionalidad del DAG: Este dag obtiene todas las tareas de Vericuenta que entran por Inbound, a las que no se les pudo obtener el cep al primer intento y quedan con estatus ERROR_REINTENTAR, lo que hace el DAG es hacer los reintentos cada cierto tiempo, para la obtención del documento CEP durante un tiempo determinado (1 hora, 2 horas, etc), una vez que haya obtenido el cep, pasa la tarea a estatus RESOLVIENDO para que se publique una Vericuenta de manera normal. En caso de que en ese tiempo no haya encontrado el cep, lo que hace, es transformar esa tarea en una Vericuenta Manual, o un Veribanco, dependiendo del banco receptor que viene en la solicitud.

task_publisher

Status en el que toma la tarea: RESOLVIENDO
Status en el que sale la tarea: PUBLICADA

Tarea que trabaja el dag: Cualquier tipo de tarea que pase por Crowd (Plataforma, findepmovil, externas)
Funcionalidad del DAG: Este dag busca las tareas que se encuentren en un status de RESOLVIENDO, y hace la publicación con todo lo que conlleva como por ejemplo: agrega segmentos en la tabla de task segment, la agrega en la lista de redis con toda la configuración que toma del motor (stage, role, task identifyer, podlet, etc) por lo cual es uno de los dags mas importantes para la plataforma, ya que es quien publica las tareas que ve el operador, ya sea en la plataforma crowd o en findepmovil, como por ejemplo Verifirma presencial. Va muy de la mano con el motor de tareas ya que gracias a la configuración, el dag sabe que parametros va a tener esa tarea. En caso de que por alguna razon el dag no pueda publicar la tarea, esta pasaría a un status de NO_PUBLICADO o de DATA_EVALUATION_EXC.

vericuenta

Status en el que toma la tarea: CREADA
Status en el que sale la tarea: ERROR REINTENTAR / RESOLVIENDO

Tarea que trabaja el dag: Vericuentas desde Inboud
Funcionalidad del DAG: Este dag busca las tareas de Vericuenta que entran por inbound (Con todas sus variables como: Vericuenta, Veribanco, Vericuenta Manual) que se encuentren en el status de "CREADA", lo que hace este dag, es que se encarga de hacer la petición del documento CEP de las tareas de Vericuenta, en el caso de que lo obtenga en la primera vez, pasa la tarea a RESOLVIENDO, en caso de que no pueda obtener el cep, pone la tarea en el status de ERROR_REINTENTAR para que lo pueda obtener el dag de error_recovery.

veridatos

Status en el que toma la tarea: CREADA
Status en el que sale la tarea: RESOLVIENDO

Tarea que trabaja el dag: Veridatos
Funcionalidad del DAG: Este dag busca las tareas de veridatos que se encuentren en el status de "CREADA", lo que hace este dag, es que se encarga de  

veridomi

Status en el que toma la tarea: CREADA
Status en el que sale la tarea: RESOLVIENDO

Tarea que trabaja el dag: Veridomi
Funcionalidad del DAG: Este dag busca las tareas de veridatos que se encuentren en el status de "CREADA", lo que hace este dag, es que se encarga de  

verifsim

Status en el que toma la tarea: N/A
Status en el que sale la tarea: PUBLICADA

Tarea que trabaja el dag: FSIM
Funcionalidad del DAG: Este dag obtiene un archivo FSIM en formato excel, para poder hacer la extracción de datos del documento. Si el dag logra obtener todos los datos de manera correcta, este creará una tarea en task segments, pero no la publicará a redis, ya que esta se resuelve de manera automatica. En ese caso, mandaria de respuesta una validacion APROBADA. En caso de que el dag no pueda obtener los datos de manera correcta (ya sea porque esta dañado, el formato del documento es erroneo o simplemente no es un archivo excel) de igualmanera creara el segmento en la tabla de task segments, pero esta vez mandará una respuesta automatica de ERROR, haciendo incapié en los datos que no se pudieron extraer.

videocall_compositions

Repositorio