terraform: Destroy node should only include deposed for specific index
Fixes #10338 The destruction step for a resource was included the deposed resources for _all_ resources with that name (ignoring the "index"). For example: `aws_instance.foo.0` was including destroying deposed for `aws_instance.foo.1`. This changes the config to the deposed transformer to properly include that index. This change includes a larger change of changing `stateId` to include the index. This affected more parts but was ultimately the issue in question.
This commit is contained in:
parent
3bf93501a1
commit
3b2282ca57
|
@ -23,9 +23,6 @@ func (n *NodeApplyableResource) EvalTree() EvalNode {
|
||||||
|
|
||||||
// stateId is the ID to put into the state
|
// stateId is the ID to put into the state
|
||||||
stateId := addr.stateId()
|
stateId := addr.stateId()
|
||||||
if addr.Index > -1 {
|
|
||||||
stateId = fmt.Sprintf("%s.%d", stateId, addr.Index)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build the instance info. More of this will be populated during eval
|
// Build the instance info. More of this will be populated during eval
|
||||||
info := &InstanceInfo{
|
info := &InstanceInfo{
|
||||||
|
|
|
@ -48,7 +48,7 @@ func (n *NodeDestroyResource) References() []string {
|
||||||
// GraphNodeDynamicExpandable
|
// GraphNodeDynamicExpandable
|
||||||
func (n *NodeDestroyResource) DynamicExpand(ctx EvalContext) (*Graph, error) {
|
func (n *NodeDestroyResource) DynamicExpand(ctx EvalContext) (*Graph, error) {
|
||||||
// If we have no config we do nothing
|
// If we have no config we do nothing
|
||||||
if n.Config == nil {
|
if n.Addr == nil {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -62,7 +62,7 @@ func (n *NodeDestroyResource) DynamicExpand(ctx EvalContext) (*Graph, error) {
|
||||||
// We want deposed resources in the state to be destroyed
|
// We want deposed resources in the state to be destroyed
|
||||||
steps = append(steps, &DeposedTransformer{
|
steps = append(steps, &DeposedTransformer{
|
||||||
State: state,
|
State: state,
|
||||||
View: n.Config.Id(),
|
View: n.Addr.stateId(),
|
||||||
})
|
})
|
||||||
|
|
||||||
// Target
|
// Target
|
||||||
|
@ -85,9 +85,6 @@ func (n *NodeDestroyResource) DynamicExpand(ctx EvalContext) (*Graph, error) {
|
||||||
func (n *NodeDestroyResource) EvalTree() EvalNode {
|
func (n *NodeDestroyResource) EvalTree() EvalNode {
|
||||||
// stateId is the ID to put into the state
|
// stateId is the ID to put into the state
|
||||||
stateId := n.Addr.stateId()
|
stateId := n.Addr.stateId()
|
||||||
if n.Addr.Index > -1 {
|
|
||||||
stateId = fmt.Sprintf("%s.%d", stateId, n.Addr.Index)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build the instance info. More of this will be populated during eval
|
// Build the instance info. More of this will be populated during eval
|
||||||
info := &InstanceInfo{
|
info := &InstanceInfo{
|
||||||
|
|
|
@ -0,0 +1,67 @@
|
||||||
|
package terraform
|
||||||
|
|
||||||
|
import (
|
||||||
|
"strings"
|
||||||
|
"sync"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestNodeDestroyResourceDynamicExpand_deposedCount(t *testing.T) {
|
||||||
|
var stateLock sync.RWMutex
|
||||||
|
state := &State{
|
||||||
|
Modules: []*ModuleState{
|
||||||
|
&ModuleState{
|
||||||
|
Path: rootModulePath,
|
||||||
|
Resources: map[string]*ResourceState{
|
||||||
|
"aws_instance.bar.0": &ResourceState{
|
||||||
|
Type: "aws_instance",
|
||||||
|
Deposed: []*InstanceState{
|
||||||
|
&InstanceState{
|
||||||
|
ID: "foo",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
"aws_instance.bar.1": &ResourceState{
|
||||||
|
Type: "aws_instance",
|
||||||
|
Deposed: []*InstanceState{
|
||||||
|
&InstanceState{
|
||||||
|
ID: "bar",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
addr, err := parseResourceAddressInternal("aws_instance.bar.0")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("err: %s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
m := testModule(t, "apply-cbd-count")
|
||||||
|
n := &NodeDestroyResource{
|
||||||
|
NodeAbstractResource: &NodeAbstractResource{
|
||||||
|
Addr: addr,
|
||||||
|
ResourceState: state.Modules[0].Resources["aws_instance.bar.0"],
|
||||||
|
Config: m.Config().Resources[0],
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
g, err := n.DynamicExpand(&MockEvalContext{
|
||||||
|
PathPath: []string{"root"},
|
||||||
|
StateState: state,
|
||||||
|
StateLock: &stateLock,
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("err: %s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
actual := strings.TrimSpace(g.String())
|
||||||
|
expected := strings.TrimSpace(`
|
||||||
|
aws_instance.bar.0 (deposed #0)
|
||||||
|
`)
|
||||||
|
if actual != expected {
|
||||||
|
t.Fatalf("bad:\n\n%s", actual)
|
||||||
|
}
|
||||||
|
}
|
|
@ -1,9 +1,5 @@
|
||||||
package terraform
|
package terraform
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
)
|
|
||||||
|
|
||||||
// NodePlanDestroyableResource represents a resource that is "applyable":
|
// NodePlanDestroyableResource represents a resource that is "applyable":
|
||||||
// it is ready to be applied and is represented by a diff.
|
// it is ready to be applied and is represented by a diff.
|
||||||
type NodePlanDestroyableResource struct {
|
type NodePlanDestroyableResource struct {
|
||||||
|
@ -21,9 +17,6 @@ func (n *NodePlanDestroyableResource) EvalTree() EvalNode {
|
||||||
|
|
||||||
// stateId is the ID to put into the state
|
// stateId is the ID to put into the state
|
||||||
stateId := addr.stateId()
|
stateId := addr.stateId()
|
||||||
if addr.Index > -1 {
|
|
||||||
stateId = fmt.Sprintf("%s.%d", stateId, addr.Index)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build the instance info. More of this will be populated during eval
|
// Build the instance info. More of this will be populated during eval
|
||||||
info := &InstanceInfo{
|
info := &InstanceInfo{
|
||||||
|
|
|
@ -19,9 +19,6 @@ func (n *NodePlannableResourceInstance) EvalTree() EvalNode {
|
||||||
|
|
||||||
// stateId is the ID to put into the state
|
// stateId is the ID to put into the state
|
||||||
stateId := addr.stateId()
|
stateId := addr.stateId()
|
||||||
if addr.Index > -1 {
|
|
||||||
stateId = fmt.Sprintf("%s.%d", stateId, addr.Index)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build the instance info. More of this will be populated during eval
|
// Build the instance info. More of this will be populated during eval
|
||||||
info := &InstanceInfo{
|
info := &InstanceInfo{
|
||||||
|
|
|
@ -1,9 +1,5 @@
|
||||||
package terraform
|
package terraform
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
)
|
|
||||||
|
|
||||||
// NodePlannableResourceOrphan represents a resource that is "applyable":
|
// NodePlannableResourceOrphan represents a resource that is "applyable":
|
||||||
// it is ready to be applied and is represented by a diff.
|
// it is ready to be applied and is represented by a diff.
|
||||||
type NodePlannableResourceOrphan struct {
|
type NodePlannableResourceOrphan struct {
|
||||||
|
@ -20,9 +16,6 @@ func (n *NodePlannableResourceOrphan) EvalTree() EvalNode {
|
||||||
|
|
||||||
// stateId is the ID to put into the state
|
// stateId is the ID to put into the state
|
||||||
stateId := addr.stateId()
|
stateId := addr.stateId()
|
||||||
if addr.Index > -1 {
|
|
||||||
stateId = fmt.Sprintf("%s.%d", stateId, addr.Index)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build the instance info. More of this will be populated during eval
|
// Build the instance info. More of this will be populated during eval
|
||||||
info := &InstanceInfo{
|
info := &InstanceInfo{
|
||||||
|
|
|
@ -102,6 +102,9 @@ func (r *ResourceAddress) stateId() string {
|
||||||
default:
|
default:
|
||||||
panic(fmt.Errorf("unknown resource mode: %s", r.Mode))
|
panic(fmt.Errorf("unknown resource mode: %s", r.Mode))
|
||||||
}
|
}
|
||||||
|
if r.Index >= 0 {
|
||||||
|
result += fmt.Sprintf(".%d", r.Index)
|
||||||
|
}
|
||||||
|
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
|
|
|
@ -571,7 +571,7 @@ func TestResourceAddressStateId(t *testing.T) {
|
||||||
"aws_instance.foo",
|
"aws_instance.foo",
|
||||||
},
|
},
|
||||||
|
|
||||||
"basic resource ignores count": {
|
"basic resource with index": {
|
||||||
&ResourceAddress{
|
&ResourceAddress{
|
||||||
Mode: config.ManagedResourceMode,
|
Mode: config.ManagedResourceMode,
|
||||||
Type: "aws_instance",
|
Type: "aws_instance",
|
||||||
|
@ -579,7 +579,7 @@ func TestResourceAddressStateId(t *testing.T) {
|
||||||
InstanceType: TypePrimary,
|
InstanceType: TypePrimary,
|
||||||
Index: 2,
|
Index: 2,
|
||||||
},
|
},
|
||||||
"aws_instance.foo",
|
"aws_instance.foo.2",
|
||||||
},
|
},
|
||||||
|
|
||||||
"data resource": {
|
"data resource": {
|
||||||
|
|
Loading…
Reference in New Issue