From df3fea32de35613d828acc68106885f6ffaeef23 Mon Sep 17 00:00:00 2001 From: Christopher Moussa Date: Thu, 15 Jul 2021 12:45:27 -0700 Subject: [PATCH] bulk_update.py: add "max_jobs" key-value pair Add the "max_jobs" key-value pair to each user's payload information to be sent to the priority plugin. --- src/plugins/bulk_update.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/plugins/bulk_update.py b/src/plugins/bulk_update.py index 4728a6e59..8fea58114 100755 --- a/src/plugins/bulk_update.py +++ b/src/plugins/bulk_update.py @@ -48,7 +48,7 @@ def bulk_update(path): # fetch all rows from association_table (will print out tuples) for row in cur.execute( - "SELECT userid, bank, default_bank, fairshare FROM association_table" + "SELECT userid, bank, default_bank, fairshare, max_jobs FROM association_table" ): # create a JSON payload with the results of the query data = { @@ -56,6 +56,7 @@ def bulk_update(path): "bank": str(row[1]), "default_bank": str(row[2]), "fairshare": str(row[3]), + "max_jobs": str(row[4]), } flux.Flux().rpc("job-manager.mf_priority.rec_update", data).get()