fixes

.github/actions/debug-wait/action.yaml

@@ -0,0 +1,15 @@
+---
+name: "Debug wait"
+description: "If debugging is enabled, wait"
+
+runs:
+  using: composite
+  steps:
+    - name: "Debug: SSH to runner"
+      uses: scality/actions/[email protected]
+      continue-on-error: true
+      with:
+        tmate-server-host: ${{ env.TMATE_SERVER_HOST }}
+        tmate-server-port: ${{ env.TMATE_SERVER_PORT }}
+        tmate-server-rsa-fingerprint: ${{ env.TMATE_SERVER_RSA_FINGERPRINT }}
+        tmate-server-ed25519-fingerprint: ${{ env.TMATE_SERVER_ED25519_FINGERPRINT }}

.github/workflows/tests.yaml

@@ -3,6 +3,11 @@ name: tests
 
 env:
   GINKGO_VERSION: v1.15.2
+  # DEBUG WAIT
+  TMATE_SERVER_HOST: ${{ secrets.TMATE_SERVER_HOST }}
+  TMATE_SERVER_PORT: ${{ secrets.TMATE_SERVER_PORT }}
+  TMATE_SERVER_RSA_FINGERPRINT: ${{ secrets.TMATE_SERVER_RSA_FINGERPRINT }}
+  TMATE_SERVER_ED25519_FINGERPRINT: ${{ secrets.TMATE_SERVER_ED25519_FINGERPRINT }}
 
 on:
   push:
@@ -172,6 +177,11 @@ jobs:
       with:
         testsuite: ingestion
         token: ${{ secrets.CODECOV_TOKEN }}
+
+    - name: Debug wait
+      uses: ./.github/actions/debug-wait
+      timeout-minutes: 90
+      if: always()
 
     - name: run misc functional tests
       uses: ./.github/actions/ft-test

extensions/utils/LocationStatusStream.js

@@ -106,21 +106,25 @@ class LocationStatusStream {
      */
     _initializeLocationStatuses(cb) {
         this._locationStatusColl.find({})
-            .toArray((err, locations) => {
-                if (err) {
-                    this._log.error('Could not fetch location statuses from mongo', {
-                        method: 'ServiceStatusManager._initializeLocationStatuses',
-                        error: err.message,
-                    });
-                    return cb(err);
-                }
+            .toArray()
+            .then(locations => {
                 locations.forEach(location => {
                     const isPaused = location.value[this._serviceName].paused;
                     if (isPaused) {
                         this._pauseServiceForLocation(location._id);
                     }
                 });
                 return cb();
+
+            })
+            .catch( err => {
+                if (err) {
+                    this._log.error('Could not fetch location statuses from mongo', {
+                        method: 'ServiceStatusManager._initializeLocationStatuses',
+                        error: err.message,
+                    });
+                    return cb(err);
+                }
             });
     }