destroy for jobs + test

Author: denik

acceptance/bundle/resources/jobs/output.txt

@@ -88,3 +88,63 @@ Deployment complete!
   "path": "/api/2.2/jobs/reset"
 }
 jobs foo id='[TEST_JOB_ID+0]' name='foo'
+
+=== Fetch job ID and verify remote state
+>>> [CLI] jobs get [TEST_JOB_ID+0]
+{
+  "job_id":[TEST_JOB_ID+0],
+  "settings": {
+    "deployment": {
+      "kind":"BUNDLE",
+      "metadata_file_path":"/Workspace/Users/[USERNAME]/.bundle/test-bundle/default/state/metadata.json"
+    },
+    "edit_mode":"UI_LOCKED",
+    "format":"MULTI_TASK",
+    "job_clusters": [
+      {
+        "job_cluster_key":"key",
+        "new_cluster": {
+          "num_workers":0,
+          "spark_version":"13.3.x-scala2.12"
+        }
+      }
+    ],
+    "max_concurrent_runs":1,
+    "name":"foo",
+    "queue": {
+      "enabled":true
+    },
+    "trigger": {
+      "pause_status":"UNPAUSED",
+      "periodic": {
+        "interval":1,
+        "unit":"HOURS"
+      }
+    }
+  }
+}
+
+=== Destroy the job and verify that it's removed from the state and from remote
+>>> [CLI] bundle destroy --auto-approve
+The following resources will be deleted:
+  delete job foo
+
+All files and directories at the following location will be deleted: /Workspace/Users/[USERNAME]/.bundle/test-bundle/default
+
+Deleting files...
+Destroy complete!
+
+>>> print_requests
+{
+  "body": {
+    "job_id": [TEST_JOB_ID+0]
+  },
+  "method": "POST",
+  "path": "/api/2.2/jobs/delete"
+}
+State not found for jobs.foo
+
+>>> musterr [CLI] jobs get [TEST_JOB_ID+0]
+Error: Not Found
+
+Exit code (musterr): 1

acceptance/bundle/resources/jobs/script

@@ -13,3 +13,17 @@ title "Update trigger.periodic.unit and re-deploy"
 trace update_file.py databricks.yml DAYS HOURS
 trace $CLI bundle deploy
 trace print_requests
+
+title "Fetch job ID and verify remote state"
+
+ppid=`read_id.py jobs foo`
+
+trace $CLI jobs get $ppid
+rm out.requests.txt
+
+title "Destroy the job and verify that it's removed from the state and from remote"
+trace $CLI bundle destroy --auto-approve
+trace print_requests
+
+trace musterr $CLI jobs get $ppid
+rm out.requests.txt

bundle/terranova/terranova_resources/job.go

@@ -53,6 +53,14 @@ func (r *ResourceJob) DoUpdate(ctx context.Context, id string) (string, error) {
 }
 
 func (r *ResourceJob) DoDelete(ctx context.Context, id string) error {
+	idInt, err := strconv.ParseInt(id, 10, 64)
+	if err != nil {
+		return err
+	}
+	r.client.Jobs.DeleteByJobId(ctx, idInt)
+	if err != nil {
+		return SDKError{Method: "Jobs.DeleteByJobId", Err: err}
+	}
 	return nil
 }