terraform: on_failure for provisioners
This commit is contained in:
parent
85cb3a16b0
commit
4a8c2d0958
|
@ -4117,6 +4117,150 @@ aws_instance.foo:
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Verify that on destroy provisioner failure with "continue" that
|
||||||
|
// we continue to the next provisioner.
|
||||||
|
func TestContext2Apply_provisionerDestroyFailContinue(t *testing.T) {
|
||||||
|
m := testModule(t, "apply-provisioner-destroy-continue")
|
||||||
|
p := testProvider("aws")
|
||||||
|
pr := testProvisioner()
|
||||||
|
p.ApplyFn = testApplyFn
|
||||||
|
p.DiffFn = testDiffFn
|
||||||
|
|
||||||
|
var calls []string
|
||||||
|
pr.ApplyFn = func(rs *InstanceState, c *ResourceConfig) error {
|
||||||
|
val, ok := c.Config["foo"]
|
||||||
|
if !ok {
|
||||||
|
t.Fatalf("bad value for foo: %v %#v", val, c)
|
||||||
|
}
|
||||||
|
|
||||||
|
calls = append(calls, val.(string))
|
||||||
|
return fmt.Errorf("provisioner error")
|
||||||
|
}
|
||||||
|
|
||||||
|
state := &State{
|
||||||
|
Modules: []*ModuleState{
|
||||||
|
&ModuleState{
|
||||||
|
Path: rootModulePath,
|
||||||
|
Resources: map[string]*ResourceState{
|
||||||
|
"aws_instance.foo": &ResourceState{
|
||||||
|
Type: "aws_instance",
|
||||||
|
Primary: &InstanceState{
|
||||||
|
ID: "bar",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx := testContext2(t, &ContextOpts{
|
||||||
|
Module: m,
|
||||||
|
State: state,
|
||||||
|
Destroy: true,
|
||||||
|
Providers: map[string]ResourceProviderFactory{
|
||||||
|
"aws": testProviderFuncFixed(p),
|
||||||
|
},
|
||||||
|
Provisioners: map[string]ResourceProvisionerFactory{
|
||||||
|
"shell": testProvisionerFuncFixed(pr),
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
|
if _, err := ctx.Plan(); err != nil {
|
||||||
|
t.Fatalf("err: %s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
state, err := ctx.Apply()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatalf("err: %s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
checkStateString(t, state, `<no state>`)
|
||||||
|
|
||||||
|
// Verify apply was invoked
|
||||||
|
if !pr.ApplyCalled {
|
||||||
|
t.Fatalf("provisioner not invoked")
|
||||||
|
}
|
||||||
|
|
||||||
|
expected := []string{"one", "two"}
|
||||||
|
if !reflect.DeepEqual(calls, expected) {
|
||||||
|
t.Fatalf("bad: %#v", calls)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify that on destroy provisioner failure with "continue" that
|
||||||
|
// we continue to the next provisioner. But if the next provisioner defines
|
||||||
|
// to fail, then we fail after running it.
|
||||||
|
func TestContext2Apply_provisionerDestroyFailContinueFail(t *testing.T) {
|
||||||
|
m := testModule(t, "apply-provisioner-destroy-fail")
|
||||||
|
p := testProvider("aws")
|
||||||
|
pr := testProvisioner()
|
||||||
|
p.ApplyFn = testApplyFn
|
||||||
|
p.DiffFn = testDiffFn
|
||||||
|
|
||||||
|
var calls []string
|
||||||
|
pr.ApplyFn = func(rs *InstanceState, c *ResourceConfig) error {
|
||||||
|
val, ok := c.Config["foo"]
|
||||||
|
if !ok {
|
||||||
|
t.Fatalf("bad value for foo: %v %#v", val, c)
|
||||||
|
}
|
||||||
|
|
||||||
|
calls = append(calls, val.(string))
|
||||||
|
return fmt.Errorf("provisioner error")
|
||||||
|
}
|
||||||
|
|
||||||
|
state := &State{
|
||||||
|
Modules: []*ModuleState{
|
||||||
|
&ModuleState{
|
||||||
|
Path: rootModulePath,
|
||||||
|
Resources: map[string]*ResourceState{
|
||||||
|
"aws_instance.foo": &ResourceState{
|
||||||
|
Type: "aws_instance",
|
||||||
|
Primary: &InstanceState{
|
||||||
|
ID: "bar",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx := testContext2(t, &ContextOpts{
|
||||||
|
Module: m,
|
||||||
|
State: state,
|
||||||
|
Destroy: true,
|
||||||
|
Providers: map[string]ResourceProviderFactory{
|
||||||
|
"aws": testProviderFuncFixed(p),
|
||||||
|
},
|
||||||
|
Provisioners: map[string]ResourceProvisionerFactory{
|
||||||
|
"shell": testProvisionerFuncFixed(pr),
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
|
if _, err := ctx.Plan(); err != nil {
|
||||||
|
t.Fatalf("err: %s", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
state, err := ctx.Apply()
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("should error")
|
||||||
|
}
|
||||||
|
|
||||||
|
checkStateString(t, state, `
|
||||||
|
aws_instance.foo:
|
||||||
|
ID = bar
|
||||||
|
`)
|
||||||
|
|
||||||
|
// Verify apply was invoked
|
||||||
|
if !pr.ApplyCalled {
|
||||||
|
t.Fatalf("provisioner not invoked")
|
||||||
|
}
|
||||||
|
|
||||||
|
expected := []string{"one", "two"}
|
||||||
|
if !reflect.DeepEqual(calls, expected) {
|
||||||
|
t.Fatalf("bad: %#v", calls)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// Verify destroy provisioners are not run for tainted instances.
|
// Verify destroy provisioners are not run for tainted instances.
|
||||||
func TestContext2Apply_provisionerDestroyTainted(t *testing.T) {
|
func TestContext2Apply_provisionerDestroyTainted(t *testing.T) {
|
||||||
m := testModule(t, "apply-provisioner-destroy")
|
m := testModule(t, "apply-provisioner-destroy")
|
||||||
|
|
|
@ -306,8 +306,18 @@ func (n *EvalApplyProvisioners) apply(ctx EvalContext, provs []*config.Provision
|
||||||
|
|
||||||
// Invoke the Provisioner
|
// Invoke the Provisioner
|
||||||
output := CallbackUIOutput{OutputFn: outputFn}
|
output := CallbackUIOutput{OutputFn: outputFn}
|
||||||
if err := provisioner.Apply(&output, state, provConfig); err != nil {
|
applyErr := provisioner.Apply(&output, state, provConfig)
|
||||||
return err
|
if applyErr != nil {
|
||||||
|
// Determine failure behavior
|
||||||
|
switch prov.OnFailure {
|
||||||
|
case config.ProvisionerOnFailureContinue:
|
||||||
|
log.Printf(
|
||||||
|
"[INFO] apply: %s [%s]: error during provision, continue requested",
|
||||||
|
n.Info.Id, prov.Type)
|
||||||
|
|
||||||
|
case config.ProvisionerOnFailureFail:
|
||||||
|
return applyErr
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
{
|
{
|
||||||
|
|
|
@ -0,0 +1,15 @@
|
||||||
|
resource "aws_instance" "foo" {
|
||||||
|
foo = "bar"
|
||||||
|
|
||||||
|
provisioner "shell" {
|
||||||
|
foo = "one"
|
||||||
|
when = "destroy"
|
||||||
|
on_failure = "continue"
|
||||||
|
}
|
||||||
|
|
||||||
|
provisioner "shell" {
|
||||||
|
foo = "two"
|
||||||
|
when = "destroy"
|
||||||
|
on_failure = "continue"
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,14 @@
|
||||||
|
resource "aws_instance" "foo" {
|
||||||
|
foo = "bar"
|
||||||
|
|
||||||
|
provisioner "shell" {
|
||||||
|
foo = "one"
|
||||||
|
when = "destroy"
|
||||||
|
on_failure = "continue"
|
||||||
|
}
|
||||||
|
|
||||||
|
provisioner "shell" {
|
||||||
|
foo = "two"
|
||||||
|
when = "destroy"
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue