Skip to content

Commit b4392dd

Browse files
Fix: pass wn_gpu_map to JsonSoftwareCheck in AtlasProdJobBroker
Production tasks were missing the WN GPU monitoring data in the brokerage because wn_gpu_map was not loaded or passed. Mirrors the pattern already used in AtlasAnalJobBroker.
1 parent 1959a31 commit b4392dd

1 file changed

Lines changed: 8 additions & 1 deletion

File tree

pandajedi/jedibrokerage/AtlasProdJobBroker.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,13 @@ def __init__(self, ddmIF, taskBufferIF):
9696
logger.error("Failed to load the WN architecture level map!!!")
9797
self.architecture_level_map = {}
9898

99+
# load the worker node GPU map
100+
try:
101+
self.wn_gpu_map = taskBufferIF.get_worker_node_gpu_map()
102+
except BaseException:
103+
logger.error("Failed to load the WN GPU map!!!")
104+
self.wn_gpu_map = {}
105+
99106
def convertMBpsToWeight(self, mbps):
100107
"""
101108
Takes MBps value and converts to a weight between 1 and 2
@@ -754,7 +761,7 @@ def doBrokerage(self, taskSpec, cloudName, inputChunk, taskParamMap, hintForTB=F
754761
resolved_platforms = {}
755762
preference_weight_map = {}
756763
if taskSpec.transHome is not None:
757-
jsonCheck = AtlasBrokerUtils.JsonSoftwareCheck(self.siteMapper, self.sw_map, self.architecture_level_map)
764+
jsonCheck = AtlasBrokerUtils.JsonSoftwareCheck(self.siteMapper, self.sw_map, self.architecture_level_map, self.wn_gpu_map)
758765
unified_site_list = self.get_unified_sites(scanSiteList)
759766

760767
host_cpu_spec = taskSpec.get_host_cpu_spec()

0 commit comments

Comments
 (0)