Fix #228

Author: sylvinus

mrq/worker.py

@@ -227,13 +227,21 @@ def greenlet_paused_queues(self):
           time.sleep(self.config["paused_queues_refresh_interval"])
 
     def get_memory(self):
-        mmaps = self.process.memory_maps()
-        mem = {
-            "rss": sum([x.rss for x in mmaps]),
-            "swap": sum([getattr(x, 'swap', getattr(x, 'swapped', 0)) for x in mmaps])
-        }
-        mem["total"] = mem["rss"] + mem["swap"]
-        return mem
+
+        try:
+
+            mmaps = self.process.memory_maps()
+            mem = {
+                "rss": sum([x.rss for x in mmaps]),
+                "swap": sum([getattr(x, 'swap', getattr(x, 'swapped', 0)) for x in mmaps])
+            }
+            mem["total"] = mem["rss"] + mem["swap"]
+            return mem
+
+        # memory_maps is unavailable on macOS
+        # https://github.com/pricingassistant/mrq/issues/228
+        except Exception as e:
+            return {"total": 0, "rss": 0, "swap": 0}
 
     def get_worker_report(self, with_memory=False):
         """ Returns a dict containing all the data we can about the current status of the worker and