feat(client-emr-serverless): AWS EMR Serverless: Adds a new option in the CancelJobRun API in EMR 7.9.0+, to cancel a job with grace period. This feature is enabled by default with a 120-second grace period for streaming jobs and is not enabled by default for batch jobs.

Author: awstools

clients/client-emr-serverless/src/commands/CancelJobRunCommand.ts

@@ -38,6 +38,7 @@ export interface CancelJobRunCommandOutput extends CancelJobRunResponse, __Metad
  * const input = { // CancelJobRunRequest
  *   applicationId: "STRING_VALUE", // required
  *   jobRunId: "STRING_VALUE", // required
+ *   shutdownGracePeriodInSeconds: Number("int"),
  * };
  * const command = new CancelJobRunCommand(input);
  * const response = await client.send(command);

clients/client-emr-serverless/src/models/models_0.ts

@@ -663,6 +663,12 @@ export interface CancelJobRunRequest {
    * @public
    */
   jobRunId: string | undefined;
+
+  /**
+   * The duration (in seconds) to wait before forcefully terminating the job after cancellation is requested.
+   * @public
+   */
+  shutdownGracePeriodInSeconds?: number | undefined;
 }
 
 /**

clients/client-emr-serverless/src/protocols/Aws_restJson1.ts

@@ -105,8 +105,11 @@ export const se_CancelJobRunCommand = async (
   b.bp("/applications/{applicationId}/jobruns/{jobRunId}");
   b.p("applicationId", () => input.applicationId!, "{applicationId}", false);
   b.p("jobRunId", () => input.jobRunId!, "{jobRunId}", false);
+  const query: any = map({
+    [_sGPIS]: [() => input.shutdownGracePeriodInSeconds !== void 0, () => input[_sGPIS]!.toString()],
+  });
   let body: any;
-  b.m("DELETE").h(headers).b(body);
+  b.m("DELETE").h(headers).q(query).b(body);
   return b.build();
 };
 
@@ -1287,4 +1290,5 @@ const _m = "mode";
 const _mR = "maxResults";
 const _nT = "nextToken";
 const _s = "states";
+const _sGPIS = "shutdownGracePeriodInSeconds";
 const _tK = "tagKeys";

codegen/sdk-codegen/aws-models/emr-serverless.json

@@ -1194,6 +1194,14 @@
             "smithy.api#required": {},
             "smithy.api#resourceIdentifier": "jobRunId"
           }
+        },
+        "shutdownGracePeriodInSeconds": {
+          "target": "com.amazonaws.emrserverless#ShutdownGracePeriodInSeconds",
+          "traits": {
+            "smithy.api#default": null,
+            "smithy.api#documentation": "The duration (in seconds) to wait before forcefully terminating the job after cancellation is requested.",
+            "smithy.api#httpQuery": "shutdownGracePeriodInSeconds"
+          }
         }
       }
     },
@@ -1638,8 +1646,7 @@
       "type": "string",
       "traits": {
         "smithy.api#length": {
-          "min": 1,
-          "max": 10280
+          "min": 1
         },
         "smithy.api#pattern": ".*\\S.*",
         "smithy.api#sensitive": {}
@@ -1649,6 +1656,12 @@
       "type": "list",
       "member": {
         "target": "com.amazonaws.emrserverless#EntryPointArgument"
+      },
+      "traits": {
+        "smithy.api#length": {
+          "min": 0,
+          "max": 1024
+        }
       }
     },
     "com.amazonaws.emrserverless#EntryPointPath": {
@@ -3401,6 +3414,9 @@
         "smithy.api#httpError": 402
       }
     },
+    "com.amazonaws.emrserverless#ShutdownGracePeriodInSeconds": {
+      "type": "integer"
+    },
     "com.amazonaws.emrserverless#SparkSubmit": {
       "type": "structure",
       "members": {