Revision 99aabbed lib/rpc.py
| b/lib/rpc.py | ||
|---|---|---|
| 941 | 941 |
return c.GetResults().get(node, False) |
| 942 | 942 |
|
| 943 | 943 |
@staticmethod |
| 944 |
def call_jobqueue_update(node_list, file_name, content): |
|
| 944 |
def call_jobqueue_update(node_list, address_list, file_name, content):
|
|
| 945 | 945 |
"""Update job queue. |
| 946 | 946 |
|
| 947 | 947 |
This is a multi-node call. |
| 948 | 948 |
|
| 949 | 949 |
""" |
| 950 | 950 |
c = Client("jobqueue_update", [file_name, content])
|
| 951 |
c.ConnectList(node_list) |
|
| 951 |
c.ConnectList(node_list, address_list=address_list)
|
|
| 952 | 952 |
c.Run() |
| 953 | 953 |
result = c.GetResults() |
| 954 | 954 |
return result |
| ... | ... | |
| 966 | 966 |
return c.GetResults().get(node, False) |
| 967 | 967 |
|
| 968 | 968 |
@staticmethod |
| 969 |
def call_jobqueue_rename(node_list, old, new): |
|
| 969 |
def call_jobqueue_rename(node_list, address_list, old, new):
|
|
| 970 | 970 |
"""Rename a job queue file. |
| 971 | 971 |
|
| 972 | 972 |
This is a multi-node call. |
| 973 | 973 |
|
| 974 | 974 |
""" |
| 975 | 975 |
c = Client("jobqueue_rename", [old, new])
|
| 976 |
c.ConnectList(node_list) |
|
| 976 |
c.ConnectList(node_list, address_list=address_list)
|
|
| 977 | 977 |
c.Run() |
| 978 | 978 |
result = c.GetResults() |
| 979 | 979 |
return result |
Also available in: Unified diff