Skip to content

Commit e453934

Browse files
committed
fix: Added checkType() for pilotmonitoring type
1 parent b5a696d commit e453934

File tree

2 files changed

+9
-3
lines changed

2 files changed

+9
-3
lines changed

src/DIRAC/MonitoringSystem/Client/Types/PilotMonitoring.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,14 @@
1+
"""
2+
Monitoring Type for Pilot Submission
3+
"""
4+
15
from DIRAC.MonitoringSystem.Client.Types.BaseType import BaseType
26

37

48
class PilotMonitoring(BaseType):
59
def __init__(self):
610

7-
super(PilotMonitoring, self).__init__()
11+
super().__init__()
812

913
self.keyFields = ["HostName", "SiteDirector", "Site", "CE", "Queue", "Status"]
1014

@@ -22,3 +26,5 @@ def __init__(self):
2226
"Status": {"type": "keyword"},
2327
}
2428
)
29+
30+
self.checkType()

src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ def __init__(self, *args, **kwargs):
8888
self.getOutput = False
8989
self.sendAccounting = True
9090
self.sendSubmissionAccounting = True
91-
self.sendSubmissionMonitoring = True
91+
self.sendSubmissionMonitoring = False
9292
self.siteClient = None
9393
self.rssClient = None
9494
self.rssFlag = None
@@ -194,7 +194,7 @@ def beginExecution(self):
194194
"SendPilotSubmissionAccounting", self.sendSubmissionAccounting
195195
)
196196
self.sendSubmissionMonitoring = self.am_getOption(
197-
"SendPiolotSubmissionMonitoring", self.sendSubmissionMonitoring
197+
"SendPilotSubmissionMonitoring", self.sendSubmissionMonitoring
198198
)
199199

200200
# Get the site description dictionary

0 commit comments

Comments
 (0)