fix tests

Author: maelorn

mrq/agent.py

@@ -26,7 +26,7 @@ def __init__(self, worker_group=None):
         })
         self.config = get_current_config()
         self.status = "started"
-        metric.push({"type": "agent", "worker_group": self.worker_group, "agent_id": self.id})
+        metric({"type": "agent", "worker_group": self.worker_group, "agent_id": self.id})
         self.dateorchestrated = None
 
         # global redis key used to ensure only one agent orchestrator runs at a time
@@ -115,7 +115,7 @@ def get_agent_report(self):
             "datereported": datetime.datetime.utcnow(),
             "dateexpires": datetime.datetime.utcnow() + datetime.timedelta(seconds=(self.config["report_interval"] * 3) + 5)
         }
-        metric.push({"type": "agent", "worker_group": self.worker_group, "agent_id": self.id, "worker_count": len(self.pool.processes)})
+        metric({"type": "agent", "worker_group": self.worker_group, "agent_id": self.id, "worker_count": len(self.pool.processes)})
         return report
 
     def greenlet_orchestrate(self):

mrq/context.py

@@ -13,7 +13,6 @@
 from .utils import LazyObject, load_class_by_path
 from .config import get_config
 from .subpool import subpool_map, subpool_imap
-from metrics import Metric
 
 # This should be MRQ's only Python object shared by all the jobs in the same process
 _GLOBAL_CONTEXT = {
@@ -30,7 +29,6 @@
 
 # Global log object, usable from all jobs
 log = logging.getLogger("mrq.current")
-metric = Metric()
 
 
 def setup_context(**kwargs):