fix: await the logging

snyk · Jun 3, 2020 · 41cd645 · 41cd645
1 parent 9cc3451
commit 41cd645
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/lib/import/index.ts b/src/lib/import/index.ts
@@ -67,15 +67,15 @@ export async function importTarget(
       );
     }
     debug(`Received locationUrl for ${target.name}: ${locationUrl}`);
-    logImportedTarget(orgId, integrationId, target, locationUrl, loggingPath);
+    await logImportedTarget(orgId, integrationId, target, locationUrl, loggingPath);
     return {
       pollingUrl: locationUrl,
       integrationId,
       target,
       orgId,
     };
   } catch (error) {
-    logFailedImports(orgId, integrationId, target, loggingPath);
+    await logFailedImports(orgId, integrationId, target, loggingPath);
     const err: {
       message?: string | undefined;
       innerError?: string;
@@ -107,7 +107,7 @@ export async function importTargets(
         pollingUrls.push(pollingUrl);
       } catch (error) {
         const { orgId, integrationId, target } = t;
-        logFailedImports(orgId, integrationId, target, loggingPath);
+        await logFailedImports(orgId, integrationId, target, loggingPath);
         debug('Failed to process:', JSON.stringify(t), error.message);
       }
     },

diff --git a/src/lib/poll-import/index.ts b/src/lib/poll-import/index.ts
@@ -84,7 +84,7 @@ export async function pollImportUrls(
           allProjects,
           (p: Project) => !p.success,
         );
-        logFailedProjects(locationUrl, failedProjects);
+        await logFailedProjects(locationUrl, failedProjects);
         projectsArray.push(...projects);
       } catch (error) {
         logFailedPollUrls(locationUrl, error.message || error);