From cafdc8e09fef2e1f6a08e0652d41df7bf2e79f7c Mon Sep 17 00:00:00 2001
From: "Bo-Chun Louis Chen(VM)" <louistw@uab.edu>
Date: Tue, 17 Mar 2020 01:56:41 +0000
Subject: [PATCH] Add/remove whitespace
Remove trailing whitespace
Add space between '+'
---
rc_rmq.py | 2 +-
rc_util.py | 6 +++---
slurm_agent.py | 2 +-
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/rc_rmq.py b/rc_rmq.py
index 41ec7b3..42e4913 100644
--- a/rc_rmq.py
+++ b/rc_rmq.py
@@ -61,7 +61,7 @@ class RCRMQ(object):
self._connection = pika.BlockingConnection(self._parameters)
self._channel = self._connection.channel()
self._channel.exchange_declare(
- exchange=self.EXCHANGE,
+ exchange=self.EXCHANGE,
exchange_type=self.EXCHANGE_TYPE,
durable=True)
diff --git a/rc_util.py b/rc_util.py
index 3fb55fd..8b90fce 100644
--- a/rc_util.py
+++ b/rc_util.py
@@ -25,11 +25,11 @@ def worker(ch, method, properties, body):
for key, status in tasks.items():
if not status:
print("{} is not done yet.".format(key))
- done = False
+ done = False
if done:
confirm_rmq.stop_consume()
confirm_rmq.delete_queue()
-
+
def consume(username, callback, debug=False):
if debug:
sleep(5)
@@ -39,5 +39,5 @@ def consume(username, callback, debug=False):
'routing_key': 'confirm.' + username,
'cb': callback
})
-
+
return { 'success' : True }
diff --git a/slurm_agent.py b/slurm_agent.py
index 221dc8d..e07af9b 100755
--- a/slurm_agent.py
+++ b/slurm_agent.py
@@ -16,7 +16,7 @@ def slurm_account_create(ch, method, properties, body):
success = False
try:
subprocess.call(["sudo", "sacctmgr", "add", "account", username, "-i", "Descripition: Add user"])
- subprocess.call(["sudo", "sacctmgr", "add", "user", username, "account="+username, "-i"])
+ subprocess.call(["sudo", "sacctmgr", "add", "user", username, "account=" + username, "-i"])
print("SLURM account for user {} has been added".format(username))
success = True
except:
--
GitLab