-
Notifications
You must be signed in to change notification settings - Fork 0
/
original-queuetest.py
48 lines (38 loc) · 1020 Bytes
/
original-queuetest.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
from cloudmesh.cc.Queue import Job
from cloudmesh.cc.Queue import Queue
q = Queue()
queuenames = ['localuser', 'rivanna1', 'rivanna2', 'rivanna3']
for name in queuenames:
q.create(queuename=name)
print('Adding to queue . . .')
print()
for name in queuenames:
for x in range(0, 9):
jobname = f"job-{x}"
command = f"echo Hello world {x}"
q.add(jobname=jobname, queuename=name, command=command)
print("Finished adding to the queue . . . ")
print()
'''
q.list(queuename="localuser")
print('Removing from queue . . . ')
print()
q.remove(queuename='rivanna1')
q.list(queuename='rivanna1')
print("Finished removing from queue . . . ")
'''
q.run('rivanna1')
script = textwarp.dedent(
"""
cms queue craete a
cms queue craete b
cms queue craete b
cms queue add --queue=a --name=hallo --command=hostname
cms queue add a hallo hostname
cms queue list
cms queue list --queue=a
cms queue list --queue=a,b
""").strip().splitlines()
print (script)
for command in script:
Shell.run(command)