Skip to content

OSPool prio updates #245

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
matyasselmeci merged 3 commits into from
May 14, 2025
Merged

OSPool prio updates #245

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
f880ef6
Only run the prio updates on the primary in the HA setup
rynge May 13, 2025
155b380
Adjusted Danny's temp prio
rynge May 13, 2025
0ec3373
Update opensciencegrid/ospool-cm/opt/ospool/update-prios
rynge May 14, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion opensciencegrid/ospool-cm/opt/ospool/update-prios
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
# modified according to attributes such as the number of held jobs and the
# ratio of goodput to badput.

import os
import re
import sys

Expand All @@ -31,6 +32,7 @@ def step(n):

def main():
col = htcondor.Collector()
ext_hostname = os.environ.get("OSPOOL_EXT_HOSTNAME")

# find the right negotiator
neg_ad = None
Expand All @@ -41,6 +43,9 @@ def main():
if not neg_ad:
print("Unable to find the main negotiator")
sys.exit(1)
if ext_hostname not in neg_ad['Name']:
print(f"Not updating as the negotiator is running on {neg_ad['Name']}")
sys.exit(2)
neg = htcondor.Negotiator(neg_ad)
print(f"Updating negotiator {neg_ad['Name']}")

Expand All @@ -63,7 +68,7 @@ def main():
factor += held

if "daniel.morales" in ad["Name"]:
factor -= 700
factor -= 1500

# upper/lower limits on the adjustments
factor = min(factor, 10000)
Expand Down
Loading