mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-04 22:13:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

test/pylib: manager_client: convert add_server to use put_json

Browse Source 
We shall soon pass some JSON data into these requests.
This commit is contained in:
Kamil Braun
2022-11-14 17:24:10 +01:00
parent 82eb9af80d
commit ac91e9d8be
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
test/pylib/manager_client.py
View File

@@ -149,7 +149,7 @@ class ManagerClient():
async def server_add(self) -> ServerInfo:
"""Add a new server"""
try:
server_info = await self.client.get_json("/cluster/addserver")
server_info = await self.client.put_json("/cluster/addserver", {}, response_type="json")
except Exception as exc:
raise Exception("Failed to add server") from exc
try:

4
test/pylib/scylla_cluster.py
View File

@@ -769,7 +769,7 @@ class ScyllaClusterManager:
self._cluster_server_stop_gracefully)
app.router.add_get('/cluster/server/{server_id}/start', self._cluster_server_start)
app.router.add_get('/cluster/server/{server_id}/restart', self._cluster_server_restart)
app.router.add_get('/cluster/addserver', self._cluster_server_add)
app.router.add_put('/cluster/addserver', self._cluster_server_add)
app.router.add_put('/cluster/remove-node/{initiator}', self._cluster_remove_node)
app.router.add_get('/cluster/decommission-node/{server_id}',
self._cluster_decommission_node)
@@ -862,7 +862,7 @@ class ScyllaClusterManager:
ret = await self.cluster.server_restart(server_id)
return aiohttp.web.Response(status=200 if ret[0] else 500, text=ret[1])
async def _cluster_server_add(self, _request) -> aiohttp.web.Response:
async def _cluster_server_add(self, request) -> aiohttp.web.Response:
"""Add a new server"""
assert self.cluster
s_info = await self.cluster.add_server()