make sure to await cleanup (no longer returns a promise)

kanselarij-vlaanderen · Jan 11, 2020 · e5ad8b3 · e5ad8b3
1 parent 94fba51
commit e5ad8b3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 9 deletions.
diff --git a/repository/fill-intern-overheid.js b/repository/fill-intern-overheid.js
@@ -92,15 +92,13 @@ export const fillUp = async (queryEnv, agendas) => {
     await runStage('copy temp to target', queryEnv, () => {
       return copyTempToTarget(queryEnv);
     });
-    await runStage('done filling overheid', queryEnv, () => {
-      return cleanup(queryEnv);
-    });
+    await runStage('done filling overheid', queryEnv, cleanup);
     const end = moment().utc();
     logStage(start,`fill overheid ended at: ${end.format()}`, targetGraph);
   } catch (e) {
     logStage(moment(), `${e}\n${e.stack}`, queryEnv.targetGraph);
     try {
-      cleanup(queryEnv);
+      await cleanup(queryEnv);
     }catch (e2) {
       console.log(e2);
     }

diff --git a/repository/fill-intern-regering.js b/repository/fill-intern-regering.js
@@ -82,17 +82,15 @@ export const fillUp = async (queryEnv, agendas) => {
     await runStage('copy temp to target', queryEnv, () => {
       return copyTempToTarget(queryEnv);
     });
-    await runStage('cleaned up', queryEnv, () => {
-      return cleanup(queryEnv);
-    });
+    await runStage('cleaned up', queryEnv, cleanup);
     const end = moment().utc();
     logStage(start, `fill regering ended at: ${end.format()}`, targetGraph);
   }catch (e) {
     logStage(moment(), `${e}\n${e.stack}`, queryEnv.targetGraph);
     try {
-      cleanup(queryEnv);
+      await cleanup(queryEnv);
     }catch (e2) {
       console.log(e2);
     }
   }
-};
+};