summaryrefslogtreecommitdiffstats
path: root/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bin')
-rwxr-xr-xbin/reproducible_scheduler.py30
1 files changed, 24 insertions, 6 deletions
diff --git a/bin/reproducible_scheduler.py b/bin/reproducible_scheduler.py
index 74eae0c2..e13fdccd 100755
--- a/bin/reproducible_scheduler.py
+++ b/bin/reproducible_scheduler.py
@@ -27,21 +27,40 @@ from reproducible_html_packages import gen_packages_html
from reproducible_html_packages import purge_old_pages
"""
-How the scheduler chose which limit to apply:
-everything depends on how many packages are already scheduled, in a 3 steps
-process. Let's go by an example:
+How the scheduler chooses which limit to apply, based on the MAXIMA
+and LIMIT arrays:
+
+First, the scheduler is only started for an architecture if the number of
+currently scheduled packages is lower than MAXIMA*2. Then if the number of
+scheduled packages is higher than MAXIMA, only new versions are scheduled...
+
+
+Then, for each category (totally _untested_ packages, _new_ versions,
+_ftbfs_ packages and _old_ versions) it depends on how many packages are
+already scheduled in that category, in a 3 steps process.
+
+
+Let's go by an example:
'unstable': {1: (250, 40), 2: (350, 20), '*': 5},
+is translated to:
+
if total < 250:
40
elif total < 350:
20
else:
5
+
* 1st step, if there are less than 250 packages in the queue, schedule 40
* 2nd step, if there are less than 350 packages in the queue, schedule 20
* 3rd step, schedule 5
+
So, the 3rd step happens only when there are more than 350 packages queued up.
+
+
"""
+MAXIMA = {'amd64': 750, 'armhf': 250}
+
LIMITS = {
'untested': {
'amd64': {
@@ -93,7 +112,6 @@ LIMITS = {
}
}
-MAXIMUM = {'amd64': 750, 'armhf': 250}
class Limit:
@@ -447,7 +465,7 @@ def scheduler(arch):
'WHERE s.architecture="{arch}"'
total = int(query_db(query.format(arch=arch))[0][0])
log.info('Currently scheduled packages in all suites on ' + arch + ': ' + str(total))
- if total > MAXIMUM[arch]:
+ if total > MAXIMA[arch]:
log.info(str(total) + ' packages already scheduled' +
', only scheduling new versions.')
empty_pkgs = {}
@@ -534,7 +552,7 @@ if __name__ == '__main__':
for arch in ARCHS:
log.info('Scheduling for %s...', arch)
overall = int(query_db(query.format(arch))[0][0])
- if overall > (MAXIMUM[arch]*2):
+ if overall > (MAXIMA[arch]*2):
log.info('%s packages already scheduled for %s, nothing to do.', overall, arch)
continue
log.info('%s packages already scheduled for %s, probably scheduling some '