Send n_cpus for the current node in the resources stream
@@ -123,6 +123,7 @@ def get_container_resources(node, container, gpu_resources):
'experiment_uuid': experiment_uuid,
'container_id': container.id,
'cpu_percentage': cpu_percentage,
+ 'n_cpu': num_cpu_cores,
'percpu_percentage': percpu_percentage,
'memory_used': memory_used,
'memory_limit': memory_limit,
