Skip to content
Snippets Groups Projects
Commit cafdc8e0 authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Add/remove whitespace

Remove trailing whitespace
Add space between '+'
parent 16e24b6a
No related branches found
No related tags found
2 merge requests!23Feat resolve uid gid,!18Redesign RabbitMQ
...@@ -61,7 +61,7 @@ class RCRMQ(object): ...@@ -61,7 +61,7 @@ class RCRMQ(object):
self._connection = pika.BlockingConnection(self._parameters) self._connection = pika.BlockingConnection(self._parameters)
self._channel = self._connection.channel() self._channel = self._connection.channel()
self._channel.exchange_declare( self._channel.exchange_declare(
exchange=self.EXCHANGE, exchange=self.EXCHANGE,
exchange_type=self.EXCHANGE_TYPE, exchange_type=self.EXCHANGE_TYPE,
durable=True) durable=True)
......
...@@ -25,11 +25,11 @@ def worker(ch, method, properties, body): ...@@ -25,11 +25,11 @@ def worker(ch, method, properties, body):
for key, status in tasks.items(): for key, status in tasks.items():
if not status: if not status:
print("{} is not done yet.".format(key)) print("{} is not done yet.".format(key))
done = False done = False
if done: if done:
confirm_rmq.stop_consume() confirm_rmq.stop_consume()
confirm_rmq.delete_queue() confirm_rmq.delete_queue()
def consume(username, callback, debug=False): def consume(username, callback, debug=False):
if debug: if debug:
sleep(5) sleep(5)
...@@ -39,5 +39,5 @@ def consume(username, callback, debug=False): ...@@ -39,5 +39,5 @@ def consume(username, callback, debug=False):
'routing_key': 'confirm.' + username, 'routing_key': 'confirm.' + username,
'cb': callback 'cb': callback
}) })
return { 'success' : True } return { 'success' : True }
...@@ -16,7 +16,7 @@ def slurm_account_create(ch, method, properties, body): ...@@ -16,7 +16,7 @@ def slurm_account_create(ch, method, properties, body):
success = False success = False
try: try:
subprocess.call(["sudo", "sacctmgr", "add", "account", username, "-i", "Descripition: Add user"]) 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)) print("SLURM account for user {} has been added".format(username))
success = True success = True
except: except:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment