summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorThorsten Behrens <thorsten.behrens@allotropia.de>2022-08-06 00:48:16 +0200
committerThorsten Behrens <thorsten.behrens@allotropia.de>2022-08-06 00:53:47 +0200
commit7716a43e76fe26ba31393b31cfa967f5fcb6e747 (patch)
treeaa08d7085847895c65bb7232aa94d895d64fcfa4
parent00014558d615c7004e133e2a2cb535d07f4691a2 (diff)
Make parallelism configurable for BZ attachment fetchers
Both forum and BZ document fetchers use a hardcoded size for their threadpools. Use the habitual env var PARALLELISM to override that optionally. Change-Id: I374a33ab0cfe481e0940a1f4d5d9a53ae647f135 Reviewed-on: https://gerrit.libreoffice.org/c/core/+/137888 Tested-by: Thorsten Behrens <thorsten.behrens@allotropia.de> Reviewed-by: Thorsten Behrens <thorsten.behrens@allotropia.de>
-rwxr-xr-xbin/get-bugzilla-attachments-by-mimetype3
-rwxr-xr-xbin/get-forum-attachments.py4
2 files changed, 4 insertions, 3 deletions
diff --git a/bin/get-bugzilla-attachments-by-mimetype b/bin/get-bugzilla-attachments-by-mimetype
index 349f428f73bc..6ce2a82d30eb 100755
--- a/bin/get-bugzilla-attachments-by-mimetype
+++ b/bin/get-bugzilla-attachments-by-mimetype
@@ -415,7 +415,8 @@ def generate_multi_threading():
jobs.join()
-max_threads = 20 # Number of threads to create, (1 = without multi-threading)
+# Number of threads to create, (1 = without multi-threading, default = 20)
+max_threads = int(os.environ.get('PARALLELISM', 20))
jobs = queue.Queue()
generate_multi_threading()
diff --git a/bin/get-forum-attachments.py b/bin/get-forum-attachments.py
index 18e9259d2133..92d30ccb183a 100755
--- a/bin/get-forum-attachments.py
+++ b/bin/get-forum-attachments.py
@@ -160,8 +160,8 @@ if __name__ == '__main__':
sys.exit(1)
processes = []
- # 10 at a time seems to work fine
- with ThreadPoolExecutor(max_workers=10) as executor:
+ # by default, 10 at a time seems to work fine
+ with ThreadPoolExecutor(max_workers=int(os.environ.get('PARALLELISM', 10))) as executor:
for lang, config in forums.items():
processes.append(executor.submit(get_attachments_from_url, lang, config, pathes))