merge master branch (for the new command when the master leaved)
This commit is contained in:
commit
2b1c8890a9
@ -97,8 +97,14 @@ class ClusterCommunicationModule():
|
|||||||
self.client_sock.send(f'[STOP_CHECK] {json.dumps(data)}'.encode())
|
self.client_sock.send(f'[STOP_CHECK] {json.dumps(data)}'.encode())
|
||||||
self.node_manager.docker_client.swarm.leave()
|
self.node_manager.docker_client.swarm.leave()
|
||||||
self.node_manager.status = 'none'
|
self.node_manager.status = 'none'
|
||||||
|
self.node_manager.actions = [
|
||||||
|
{'explanation': 'Add another node into our cluster', 'function': 'add_node'},
|
||||||
|
{'explanation': 'Exit', 'function': 'exit'},
|
||||||
|
]
|
||||||
|
|
||||||
print("You have leaved the cluster.")
|
print("You have leaved the cluster.")
|
||||||
|
print("Please Enter to continued")
|
||||||
|
|
||||||
return False
|
return False
|
||||||
elif command == '[START_LISTEN_TASK]':
|
elif command == '[START_LISTEN_TASK]':
|
||||||
self.client_sock.send('[START_LISTEN_TASK_CHECK] {}'.encode())
|
self.client_sock.send('[START_LISTEN_TASK_CHECK] {}'.encode())
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user