fixed bug with allocated memory

db/influx/influxdb_wrapper.py

@@ -63,7 +63,7 @@ def get_aggregator(job_id, type="text"):
     for node_id in sorted(data["node"]):
         if node_id not in allocated_nodes:
             continue
-            
+
         noded = data["node"][node_id]
         new_node = NodeData()
 
@@ -80,9 +80,9 @@ def get_aggregator(job_id, type="text"):
             new_node.alloc_mem = memd.get(node_id)
         else:
             ncpus = noded.get("sockets") * noded.get("cores_per_socket") * noded.get("virt_thr_core")
-            nmem = int(cud.get(node_id) * noded.get("main_mem") / ncpus)
-            new_node.alloc_mem = nmem 
-            
+            nmem = int(cud.get(node_id) * noded.get("main_mem") / ncpus / 1000000) #in MB
+            new_node.alloc_mem = nmem
+
         # for now we just account hyperthreading
         new_node.phys_thr_core = 1
         new_node.virt_thr_core -= 1