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