Add purge_on_delete to nomad_job resource

nomad/resource_job.go

@@ -211,6 +211,12 @@ func resourceJob() *schema.Resource {
 					},
 				},
 			},
+
+			"purge_on_delete": {
+				Description: "Whether to purge the job when the resource is deleted.",
+				Optional:    true,
+				Type:        schema.TypeBool,
+			},
 		},
 	}
 }
@@ -412,7 +418,8 @@ func resourceJobDeregister(d *schema.ResourceData, meta interface{}) error {
 	if opts.Namespace == "" {
 		opts.Namespace = "default"
 	}
-	_, _, err := client.Jobs().Deregister(id, false, opts)
+	purge := d.Get("purge_on_delete").(bool)
+	_, _, err := client.Jobs().Deregister(id, purge, opts)
 	if err != nil {
 		return fmt.Errorf("error deregistering job: %s", err)
 	}

nomad/resource_job_test.go

@@ -401,6 +401,34 @@ func TestResourceJob_parameterizedJob(t *testing.T) {
 	})
 }
 
+func TestResourceJob_purgeOnDelete(t *testing.T) {
+	r.Test(t, r.TestCase{
+		Providers: testProviders,
+		PreCheck:  func() { testAccPreCheck(t) },
+		Steps: []r.TestStep{
+			// create the resource
+			{
+				Config: testResourceJob_purgeOnDelete,
+				Check:  testResourceJob_initialCheck(t),
+			},
+			// make sure it is purged once deleted
+			{
+				Destroy: true,
+				Config:  testResourceJob_purgeOnDelete,
+				Check: func(s *terraform.State) error {
+					providerConfig := testProvider.Meta().(ProviderConfig)
+					client := providerConfig.client
+					job, _, err := client.Jobs().Info("purge-test", nil)
+					if !assert.EqualError(t, err, "Unexpected response code: 404 (job not found)") {
+						return fmt.Errorf("Job found: %#v", job)
+					}
+					return nil
+				},
+			},
+		},
+	})
+}
+
 func testResourceJob_parameterizedCheck(s *terraform.State) error {
 	resourceState := s.Modules[0].Resources["nomad_job.parameterized"]
 	if resourceState == nil {
@@ -723,6 +751,37 @@ resource "nomad_job" "test" {
 }
 `
 
+var testResourceJob_purgeOnDelete = `
+resource "nomad_job" "test" {
+    purge_on_delete = true
+    jobspec = <<EOT
+		job "foo" {
+			datacenters = ["dc1"]
+			type = "service"
+			group "foo" {
+				task "foo" {
+					driver = "raw_exec"
+					config {
+						command = "/bin/sleep"
+						args = ["30"]
+					}
+
+					resources {
+						cpu = 100
+						memory = 10
+					}
+
+					logs {
+						max_files = 3
+						max_file_size = 10
+					}
+				}
+			}
+		}
+	EOT
+}
+`
+
 func testResourceJob_initialCheck(t *testing.T) r.TestCheckFunc {
 	return testResourceJob_initialCheckNS(t, "default")
 }

website/docs/r/job.html.markdown

@@ -107,3 +107,6 @@ The following arguments are supported:
 
 - `json` `(boolean: false)` - Set this to true if your jobspec is structured with
   JSON instead of the default HCL.
+
+- `purge_on_delete` `(boolean: false)` - Set this to true if you want the job to
+  be purged when the resource is deleted.