Skip to content

Commit aa7e9aa

Browse files
committed
Added proper handling of node container removal errors.
1 parent d4682b6 commit aa7e9aa

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

deployment/dockerdeploy/deployer_newaddremove.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -789,7 +789,10 @@ func (d *Deployer) addRemoveNodes(
789789
d.logger.Info("removing node",
790790
zap.String("container", node.ContainerID))
791791

792-
d.controller.RemoveNode(ctx, node.ContainerID)
792+
err := d.controller.RemoveNode(ctx, node.ContainerID)
793+
if err != nil {
794+
return nil, errors.Wrap(err, "failed to remove node container")
795+
}
793796
}
794797

795798
if len(nodesToAdd) > 0 || len(nodesToRemove) > 0 {

0 commit comments

Comments
 (0)