@@ -942,10 +942,11 @@ def stop_host_manager(ip: str, container_ip: str, emulation: str, ip_first_octet
942
942
for node in config .cluster_config .cluster_nodes :
943
943
if node .ip == ip or ip == "" :
944
944
stopped = ClusterController .stop_host_manager (ip = ip , port = constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT ,
945
- emulation = emulation , ip_first_octet = ip_first_octet ,
946
- container_ip = container_ip )
945
+ emulation = emulation , ip_first_octet = ip_first_octet ,
946
+ container_ip = container_ip )
947
947
if stopped :
948
- click .secho (f"Stopping host with ip { container_ip } on port:{ constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT } " )
948
+ click .secho (
949
+ f"Stopping host with ip { container_ip } on port:{ constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT } " )
949
950
else :
950
951
click .secho (f"Host with ip { container_ip } is not "
951
952
f"stopped:{ constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT } " ,
@@ -1389,15 +1390,18 @@ def start_host_managers(ip: str, emulation: str, ip_first_octet: int):
1389
1390
config = MetastoreFacade .get_config (id = 1 )
1390
1391
for node in config .cluster_config .cluster_nodes :
1391
1392
if node .ip == ip or ip == "" :
1392
- operation_outcome = ClusterController .start_host_managers (ip = ip , port = constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT ,
1393
- emulation = emulation , ip_first_octet = ip_first_octet )
1393
+ operation_outcome = ClusterController .start_host_managers (ip = ip ,
1394
+ port = constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT ,
1395
+ emulation = emulation ,
1396
+ ip_first_octet = ip_first_octet )
1394
1397
if operation_outcome .outcome :
1395
1398
click .secho (f"Starting host managers on port:{ constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT } " )
1396
1399
else :
1397
1400
click .secho (f"Host managers are not started:{ constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT } " ,
1398
1401
bold = False )
1399
1402
1400
- def start_host_manager (ip : str , container_ip :str , emulation : str , ip_first_octet : int ):
1403
+
1404
+ def start_host_manager (ip : str , container_ip : str , emulation : str , ip_first_octet : int ):
1401
1405
"""
1402
1406
Utility function for starting host manager
1403
1407
@@ -1412,9 +1416,10 @@ def start_host_manager(ip: str, container_ip:str, emulation: str, ip_first_octet
1412
1416
config = MetastoreFacade .get_config (id = 1 )
1413
1417
for node in config .cluster_config .cluster_nodes :
1414
1418
if node .ip == ip or ip == "" :
1415
- operation_outcome = ClusterController .start_host_manager (ip = ip , port = constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT ,
1416
- emulation = emulation , ip_first_octet = ip_first_octet ,
1417
- container_ip = container_ip )
1419
+ operation_outcome = ClusterController .start_host_manager (ip = ip ,
1420
+ port = constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT ,
1421
+ emulation = emulation , ip_first_octet = ip_first_octet ,
1422
+ container_ip = container_ip )
1418
1423
if operation_outcome .outcome :
1419
1424
click .secho (f"Started host manager with ip { container_ip } on "
1420
1425
f"port:{ constants .GRPC_SERVERS .CLUSTER_MANAGER_PORT } " )
0 commit comments