fix(mpi): resuelve error por job que finaliza antes de lo esperado (#…

…1339) Co-authored-by: mcele <MCele>
andes · Apr 16, 2021 · 51f212c · 51f212c
1 parent 2cccb1f
commit 51f212c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 9 deletions.
diff --git a/core-v2/mpi/jobs/importarNacimientosJob.ts b/core-v2/mpi/jobs/importarNacimientosJob.ts
@@ -1,10 +1,8 @@
 import { importarNacimientos, importarDocumentosAsignados } from './nacimientosProcess';
 
 async function run(done) {
-    // PARAMETRO FECHA OPCIONAL PARA TESTEAR , el formato debe ser 'yyyy-mm-dd'
-    // let fecha='yyyy-mm-dd'
-    await importarNacimientos(done);
-    await importarDocumentosAsignados(done);
+    await importarNacimientos();
+    await importarDocumentosAsignados();
     done();
 }
 

diff --git a/core-v2/mpi/jobs/nacimientosProcess.ts b/core-v2/mpi/jobs/nacimientosProcess.ts
@@ -14,7 +14,7 @@ import { extractFoto } from '../../../core-v2/mpi/paciente/paciente.controller';
 const nacimientosLog = mpiNacimientosLog.startTrace();
 const deb = debug('nacimientosJob');
 
-// Variable utilizada en testing
+// Variable utilizada en testing (formato 'YYYY-MM-DD')
 let fechaPrueba;
 
 /**
@@ -242,7 +242,7 @@ async function procesarDataNacimientos(nacimiento) {
     }
 }
 
-export async function importarNacimientos(done) {
+export async function importarNacimientos() {
     let fecha = fechaPrueba || moment().format('YYYY-MM-DD');
     let queryFechaPath = registroProvincialData.queryFechaPath + fecha;
     const infoNacimientosArray = await getInfoPacientes(queryFechaPath);
@@ -256,13 +256,12 @@ export async function importarNacimientos(done) {
         }
     }
     deb('Proceso Importar Nacimientos Finalizado');
-    done();
 }
 
 /**
  * se actualizan los datos de todos los pacientes con dni = '' que contengan certificadoRenaper
  */
-export async function importarDocumentosAsignados(done) {
+export async function importarDocumentosAsignados() {
     try {
         // Buscamos en andes los bebes que aún no tienen documento
         let resultadoBusqueda: any = await PacienteCtr.search({ documento: '', certificadoRenaper: { $exists: true }, activo: true }, {}, userScheduler as any);
@@ -276,7 +275,6 @@ export async function importarDocumentosAsignados(done) {
         return error;
     }
     deb('Proceso Agregar documentos Faltantes Finalizado');
-    done();
 }
 
 /**