feat(client-emr-serverless): The release adds support for spark structured streaming.

Author: awstools

clients/client-emr-serverless/README.md

@@ -278,6 +278,14 @@ ListApplications
 
 [Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/emr-serverless/command/ListApplicationsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-emr-serverless/Interface/ListApplicationsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-emr-serverless/Interface/ListApplicationsCommandOutput/)
 
+</details>
+<details>
+<summary>
+ListJobRunAttempts
+</summary>
+
+[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/emr-serverless/command/ListJobRunAttemptsCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-emr-serverless/Interface/ListJobRunAttemptsCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-emr-serverless/Interface/ListJobRunAttemptsCommandOutput/)
+
 </details>
 <details>
 <summary>

clients/client-emr-serverless/src/EMRServerless.ts

@@ -33,6 +33,11 @@ import {
   ListApplicationsCommandInput,
   ListApplicationsCommandOutput,
 } from "./commands/ListApplicationsCommand";
+import {
+  ListJobRunAttemptsCommand,
+  ListJobRunAttemptsCommandInput,
+  ListJobRunAttemptsCommandOutput,
+} from "./commands/ListJobRunAttemptsCommand";
 import { ListJobRunsCommand, ListJobRunsCommandInput, ListJobRunsCommandOutput } from "./commands/ListJobRunsCommand";
 import {
   ListTagsForResourceCommand,
@@ -71,6 +76,7 @@ const commands = {
   GetDashboardForJobRunCommand,
   GetJobRunCommand,
   ListApplicationsCommand,
+  ListJobRunAttemptsCommand,
   ListJobRunsCommand,
   ListTagsForResourceCommand,
   StartApplicationCommand,
@@ -187,6 +193,23 @@ export interface EMRServerless {
     cb: (err: any, data?: ListApplicationsCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link ListJobRunAttemptsCommand}
+   */
+  listJobRunAttempts(
+    args: ListJobRunAttemptsCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<ListJobRunAttemptsCommandOutput>;
+  listJobRunAttempts(
+    args: ListJobRunAttemptsCommandInput,
+    cb: (err: any, data?: ListJobRunAttemptsCommandOutput) => void
+  ): void;
+  listJobRunAttempts(
+    args: ListJobRunAttemptsCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: ListJobRunAttemptsCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link ListJobRunsCommand}
    */

clients/client-emr-serverless/src/EMRServerlessClient.ts

@@ -63,6 +63,7 @@ import {
 } from "./commands/GetDashboardForJobRunCommand";
 import { GetJobRunCommandInput, GetJobRunCommandOutput } from "./commands/GetJobRunCommand";
 import { ListApplicationsCommandInput, ListApplicationsCommandOutput } from "./commands/ListApplicationsCommand";
+import { ListJobRunAttemptsCommandInput, ListJobRunAttemptsCommandOutput } from "./commands/ListJobRunAttemptsCommand";
 import { ListJobRunsCommandInput, ListJobRunsCommandOutput } from "./commands/ListJobRunsCommand";
 import {
   ListTagsForResourceCommandInput,
@@ -96,6 +97,7 @@ export type ServiceInputTypes =
   | GetDashboardForJobRunCommandInput
   | GetJobRunCommandInput
   | ListApplicationsCommandInput
+  | ListJobRunAttemptsCommandInput
   | ListJobRunsCommandInput
   | ListTagsForResourceCommandInput
   | StartApplicationCommandInput
@@ -116,6 +118,7 @@ export type ServiceOutputTypes =
   | GetDashboardForJobRunCommandOutput
   | GetJobRunCommandOutput
   | ListApplicationsCommandOutput
+  | ListJobRunAttemptsCommandOutput
   | ListJobRunsCommandOutput
   | ListTagsForResourceCommandOutput
   | StartApplicationCommandOutput

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

@@ -45,6 +45,7 @@ export interface GetDashboardForJobRunCommandOutput extends GetDashboardForJobRu
  * const input = { // GetDashboardForJobRunRequest
  *   applicationId: "STRING_VALUE", // required
  *   jobRunId: "STRING_VALUE", // required
+ *   attempt: Number("int"),
  * };
  * const command = new GetDashboardForJobRunCommand(input);
  * const response = await client.send(command);

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

@@ -37,6 +37,7 @@ export interface GetJobRunCommandOutput extends GetJobRunResponse, __MetadataBea
  * const input = { // GetJobRunRequest
  *   applicationId: "STRING_VALUE", // required
  *   jobRunId: "STRING_VALUE", // required
+ *   attempt: Number("int"),
  * };
  * const command = new GetJobRunCommand(input);
  * const response = await client.send(command);
@@ -133,6 +134,14 @@ export interface GetJobRunCommandOutput extends GetJobRunResponse, __MetadataBea
  * //       memoryGBHour: Number("double"),
  * //       storageGBHour: Number("double"),
  * //     },
+ * //     mode: "STRING_VALUE",
+ * //     retryPolicy: { // RetryPolicy
+ * //       maxAttempts: Number("int"),
+ * //       maxFailedAttemptsPerHour: Number("int"),
+ * //     },
+ * //     attempt: Number("int"),
+ * //     attemptCreatedAt: new Date("TIMESTAMP"),
+ * //     attemptUpdatedAt: new Date("TIMESTAMP"),
  * //   },
  * // };
  *

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

@@ -0,0 +1,113 @@
+// smithy-typescript generated code
+import { getEndpointPlugin } from "@smithy/middleware-endpoint";
+import { getSerdePlugin } from "@smithy/middleware-serde";
+import { Command as $Command } from "@smithy/smithy-client";
+import { MetadataBearer as __MetadataBearer } from "@smithy/types";
+
+import { EMRServerlessClientResolvedConfig, ServiceInputTypes, ServiceOutputTypes } from "../EMRServerlessClient";
+import { commonParams } from "../endpoint/EndpointParameters";
+import { ListJobRunAttemptsRequest, ListJobRunAttemptsResponse } from "../models/models_0";
+import { de_ListJobRunAttemptsCommand, se_ListJobRunAttemptsCommand } from "../protocols/Aws_restJson1";
+
+/**
+ * @public
+ */
+export { __MetadataBearer, $Command };
+/**
+ * @public
+ *
+ * The input for {@link ListJobRunAttemptsCommand}.
+ */
+export interface ListJobRunAttemptsCommandInput extends ListJobRunAttemptsRequest {}
+/**
+ * @public
+ *
+ * The output of {@link ListJobRunAttemptsCommand}.
+ */
+export interface ListJobRunAttemptsCommandOutput extends ListJobRunAttemptsResponse, __MetadataBearer {}
+
+/**
+ * <p>Lists all attempt of a job run.</p>
+ * @example
+ * Use a bare-bones client and the command you need to make an API call.
+ * ```javascript
+ * import { EMRServerlessClient, ListJobRunAttemptsCommand } from "@aws-sdk/client-emr-serverless"; // ES Modules import
+ * // const { EMRServerlessClient, ListJobRunAttemptsCommand } = require("@aws-sdk/client-emr-serverless"); // CommonJS import
+ * const client = new EMRServerlessClient(config);
+ * const input = { // ListJobRunAttemptsRequest
+ *   applicationId: "STRING_VALUE", // required
+ *   jobRunId: "STRING_VALUE", // required
+ *   nextToken: "STRING_VALUE",
+ *   maxResults: Number("int"),
+ * };
+ * const command = new ListJobRunAttemptsCommand(input);
+ * const response = await client.send(command);
+ * // { // ListJobRunAttemptsResponse
+ * //   jobRunAttempts: [ // JobRunAttempts // required
+ * //     { // JobRunAttemptSummary
+ * //       applicationId: "STRING_VALUE", // required
+ * //       id: "STRING_VALUE", // required
+ * //       name: "STRING_VALUE",
+ * //       mode: "STRING_VALUE",
+ * //       arn: "STRING_VALUE", // required
+ * //       createdBy: "STRING_VALUE", // required
+ * //       jobCreatedAt: new Date("TIMESTAMP"), // required
+ * //       createdAt: new Date("TIMESTAMP"), // required
+ * //       updatedAt: new Date("TIMESTAMP"), // required
+ * //       executionRole: "STRING_VALUE", // required
+ * //       state: "STRING_VALUE", // required
+ * //       stateDetails: "STRING_VALUE", // required
+ * //       releaseLabel: "STRING_VALUE", // required
+ * //       type: "STRING_VALUE",
+ * //       attempt: Number("int"),
+ * //     },
+ * //   ],
+ * //   nextToken: "STRING_VALUE",
+ * // };
+ *
+ * ```
+ *
+ * @param ListJobRunAttemptsCommandInput - {@link ListJobRunAttemptsCommandInput}
+ * @returns {@link ListJobRunAttemptsCommandOutput}
+ * @see {@link ListJobRunAttemptsCommandInput} for command's `input` shape.
+ * @see {@link ListJobRunAttemptsCommandOutput} for command's `response` shape.
+ * @see {@link EMRServerlessClientResolvedConfig | config} for EMRServerlessClient's `config` shape.
+ *
+ * @throws {@link InternalServerException} (server fault)
+ *  <p>Request processing failed because of an error or failure with the service.</p>
+ *
+ * @throws {@link ResourceNotFoundException} (client fault)
+ *  <p>The specified resource was not found.</p>
+ *
+ * @throws {@link ValidationException} (client fault)
+ *  <p>The input fails to satisfy the constraints specified by an Amazon Web Services
+ *          service.</p>
+ *
+ * @throws {@link EMRServerlessServiceException}
+ * <p>Base exception class for all service exceptions from EMRServerless service.</p>
+ *
+ * @public
+ */
+export class ListJobRunAttemptsCommand extends $Command
+  .classBuilder<
+    ListJobRunAttemptsCommandInput,
+    ListJobRunAttemptsCommandOutput,
+    EMRServerlessClientResolvedConfig,
+    ServiceInputTypes,
+    ServiceOutputTypes
+  >()
+  .ep({
+    ...commonParams,
+  })
+  .m(function (this: any, Command: any, cs: any, config: EMRServerlessClientResolvedConfig, o: any) {
+    return [
+      getSerdePlugin(config, this.serialize, this.deserialize),
+      getEndpointPlugin(config, Command.getEndpointParameterInstructions()),
+    ];
+  })
+  .s("AwsToledoWebService", "ListJobRunAttempts", {})
+  .n("EMRServerlessClient", "ListJobRunAttemptsCommand")
+  .f(void 0, void 0)
+  .ser(se_ListJobRunAttemptsCommand)
+  .de(de_ListJobRunAttemptsCommand)
+  .build() {}

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

@@ -43,6 +43,7 @@ export interface ListJobRunsCommandOutput extends ListJobRunsResponse, __Metadat
  *   states: [ // JobRunStateSet
  *     "STRING_VALUE",
  *   ],
+ *   mode: "STRING_VALUE",
  * };
  * const command = new ListJobRunsCommand(input);
  * const response = await client.send(command);
@@ -52,6 +53,7 @@ export interface ListJobRunsCommandOutput extends ListJobRunsResponse, __Metadat
  * //       applicationId: "STRING_VALUE", // required
  * //       id: "STRING_VALUE", // required
  * //       name: "STRING_VALUE",
+ * //       mode: "STRING_VALUE",
  * //       arn: "STRING_VALUE", // required
  * //       createdBy: "STRING_VALUE", // required
  * //       createdAt: new Date("TIMESTAMP"), // required
@@ -61,6 +63,9 @@ export interface ListJobRunsCommandOutput extends ListJobRunsResponse, __Metadat
  * //       stateDetails: "STRING_VALUE", // required
  * //       releaseLabel: "STRING_VALUE", // required
  * //       type: "STRING_VALUE",
+ * //       attempt: Number("int"),
+ * //       attemptCreatedAt: new Date("TIMESTAMP"),
+ * //       attemptUpdatedAt: new Date("TIMESTAMP"),
  * //     },
  * //   ],
  * //   nextToken: "STRING_VALUE",

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

@@ -100,6 +100,11 @@ export interface StartJobRunCommandOutput extends StartJobRunResponse, __Metadat
  *   },
  *   executionTimeoutMinutes: Number("long"),
  *   name: "STRING_VALUE",
+ *   mode: "STRING_VALUE",
+ *   retryPolicy: { // RetryPolicy
+ *     maxAttempts: Number("int"),
+ *     maxFailedAttemptsPerHour: Number("int"),
+ *   },
  * };
  * const command = new StartJobRunCommand(input);
  * const response = await client.send(command);

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

@@ -6,6 +6,7 @@ export * from "./GetApplicationCommand";
 export * from "./GetDashboardForJobRunCommand";
 export * from "./GetJobRunCommand";
 export * from "./ListApplicationsCommand";
+export * from "./ListJobRunAttemptsCommand";
 export * from "./ListJobRunsCommand";
 export * from "./ListTagsForResourceCommand";
 export * from "./StartApplicationCommand";

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

@@ -718,6 +718,13 @@ export interface GetDashboardForJobRunRequest {
    * @public
    */
   jobRunId: string | undefined;
+
+  /**
+   * <p>An optimal parameter that indicates the amount of attempts for the job. If not specified,
+   *          this value defaults to the attempt of the latest job.</p>
+   * @public
+   */
+  attempt?: number;
 }
 
 /**
@@ -746,6 +753,13 @@ export interface GetJobRunRequest {
    * @public
    */
   jobRunId: string | undefined;
+
+  /**
+   * <p>An optimal parameter that indicates the amount of attempts for the job. If not specified,
+   *       this value defaults to the attempt of the latest job.</p>
+   * @public
+   */
+  attempt?: number;
 }
 
 /**
@@ -875,6 +889,38 @@ export namespace JobDriver {
   };
 }
 
+/**
+ * @public
+ * @enum
+ */
+export const JobRunMode = {
+  BATCH: "BATCH",
+  STREAMING: "STREAMING",
+} as const;
+
+/**
+ * @public
+ */
+export type JobRunMode = (typeof JobRunMode)[keyof typeof JobRunMode];
+
+/**
+ * <p>The retry policy to use for a job run.</p>
+ * @public
+ */
+export interface RetryPolicy {
+  /**
+   * <p>Maximum number of attempts for the job run. This parameter is only applicable for <code>BATCH</code> mode.</p>
+   * @public
+   */
+  maxAttempts?: number;
+
+  /**
+   * <p>Maximum number of failed attempts per hour. This [arameter is only applicable for <code>STREAMING</code> mode.</p>
+   * @public
+   */
+  maxFailedAttemptsPerHour?: number;
+}
+
 /**
  * @public
  * @enum
@@ -923,6 +969,149 @@ export interface TotalResourceUtilization {
   storageGBHour?: number;
 }
 
+/**
+ * @public
+ */
+export interface ListJobRunAttemptsRequest {
+  /**
+   * <p>The ID of the application for which to list job runs.</p>
+   * @public
+   */
+  applicationId: string | undefined;
+
+  /**
+   * <p>The ID of the job run to list.</p>
+   * @public
+   */
+  jobRunId: string | undefined;
+
+  /**
+   * <p>The token for the next set of job run attempt results.</p>
+   * @public
+   */
+  nextToken?: string;
+
+  /**
+   * <p>The maximum number of job run attempts to list.</p>
+   * @public
+   */
+  maxResults?: number;
+}
+
+/**
+ * <p>The summary of attributes associated with a job run attempt.</p>
+ * @public
+ */
+export interface JobRunAttemptSummary {
+  /**
+   * <p>The ID of the application the job is running on.</p>
+   * @public
+   */
+  applicationId: string | undefined;
+
+  /**
+   * <p>The ID of the job run attempt.</p>
+   * @public
+   */
+  id: string | undefined;
+
+  /**
+   * <p>The name of the job run attempt.</p>
+   * @public
+   */
+  name?: string;
+
+  /**
+   * <p>The mode of the job run attempt.</p>
+   * @public
+   */
+  mode?: JobRunMode;
+
+  /**
+   * <p>The Amazon Resource Name (ARN) of the job run.</p>
+   * @public
+   */
+  arn: string | undefined;
+
+  /**
+   * <p>The user who created the job run.</p>
+   * @public
+   */
+  createdBy: string | undefined;
+
+  /**
+   * <p>The date and time of when the job run was created.</p>
+   * @public
+   */
+  jobCreatedAt: Date | undefined;
+
+  /**
+   * <p>The date and time when the job run attempt was created.</p>
+   * @public
+   */
+  createdAt: Date | undefined;
+
+  /**
+   * <p>The date and time of when the job run attempt was last updated.</p>
+   * @public
+   */
+  updatedAt: Date | undefined;
+
+  /**
+   * <p>The Amazon Resource Name (ARN) of the execution role of the job run..</p>
+   * @public
+   */
+  executionRole: string | undefined;
+
+  /**
+   * <p>The state of the job run attempt.</p>
+   * @public
+   */
+  state: JobRunState | undefined;
+
+  /**
+   * <p>The state details of the job run attempt.</p>
+   * @public
+   */
+  stateDetails: string | undefined;
+
+  /**
+   * <p>The Amazon EMR release label of the job run attempt.</p>
+   * @public
+   */
+  releaseLabel: string | undefined;
+
+  /**
+   * <p>The type of the job run, such as Spark or Hive.</p>
+   * @public
+   */
+  type?: string;
+
+  /**
+   * <p>The attempt number of the job run execution.</p>
+   * @public
+   */
+  attempt?: number;
+}
+
+/**
+ * @public
+ */
+export interface ListJobRunAttemptsResponse {
+  /**
+   * <p>The array of the listed job run attempt objects.</p>
+   * @public
+   */
+  jobRunAttempts: JobRunAttemptSummary[] | undefined;
+
+  /**
+   * <p>The output displays the token for the next set of application results.
+   *          This is required for pagination and is available as a response of the previous request.</p>
+   * @public
+   */
+  nextToken?: string;
+}
+
 /**
  * @public
  */
@@ -963,6 +1152,12 @@ export interface ListJobRunsRequest {
    * @public
    */
   states?: JobRunState[];
+
+  /**
+   * <p>The mode of the job runs to list.</p>
+   * @public
+   */
+  mode?: JobRunMode;
 }
 
 /**
@@ -988,6 +1183,12 @@ export interface JobRunSummary {
    */
   name?: string;
 
+  /**
+   * <p>The mode of the job run.</p>
+   * @public
+   */
+  mode?: JobRunMode;
+
   /**
    * <p>The ARN of the job run.</p>
    * @public
@@ -1042,6 +1243,24 @@ export interface JobRunSummary {
    * @public
    */
   type?: string;
+
+  /**
+   * <p>The attempt number of the job run execution.</p>
+   * @public
+   */
+  attempt?: number;
+
+  /**
+   * <p>The date and time of when the job run attempt was created.</p>
+   * @public
+   */
+  attemptCreatedAt?: Date;
+
+  /**
+   * <p>The date and time of when the job run attempt was last updated.</p>
+   * @public
+   */
+  attemptUpdatedAt?: Date;
 }
 
 /**
@@ -1701,6 +1920,36 @@ export interface JobRun {
    * @public
    */
   billedResourceUtilization?: ResourceUtilization;
+
+  /**
+   * <p>The mode of the job run.</p>
+   * @public
+   */
+  mode?: JobRunMode;
+
+  /**
+   * <p>The retry policy of the job run.</p>
+   * @public
+   */
+  retryPolicy?: RetryPolicy;
+
+  /**
+   * <p>The attempt of the job run.</p>
+   * @public
+   */
+  attempt?: number;
+
+  /**
+   * <p>The date and time of when the job run attempt was created.</p>
+   * @public
+   */
+  attemptCreatedAt?: Date;
+
+  /**
+   * <p>The date and time of when the job run attempt was last updated.</p>
+   * @public
+   */
+  attemptUpdatedAt?: Date;
 }
 
 /**
@@ -1756,6 +2005,18 @@ export interface StartJobRunRequest {
    * @public
    */
   name?: string;
+
+  /**
+   * <p>The mode of the job run when it starts.</p>
+   * @public
+   */
+  mode?: JobRunMode;
+
+  /**
+   * <p>The retry policy when job run starts.</p>
+   * @public
+   */
+  retryPolicy?: RetryPolicy;
 }
 
 /**

clients/client-emr-serverless/src/pagination/ListJobRunAttemptsPaginator.ts

@@ -0,0 +1,24 @@
+// smithy-typescript generated code
+import { createPaginator } from "@smithy/core";
+import { Paginator } from "@smithy/types";
+
+import {
+  ListJobRunAttemptsCommand,
+  ListJobRunAttemptsCommandInput,
+  ListJobRunAttemptsCommandOutput,
+} from "../commands/ListJobRunAttemptsCommand";
+import { EMRServerlessClient } from "../EMRServerlessClient";
+import { EMRServerlessPaginationConfiguration } from "./Interfaces";
+
+/**
+ * @public
+ */
+export const paginateListJobRunAttempts: (
+  config: EMRServerlessPaginationConfiguration,
+  input: ListJobRunAttemptsCommandInput,
+  ...rest: any[]
+) => Paginator<ListJobRunAttemptsCommandOutput> = createPaginator<
+  EMRServerlessPaginationConfiguration,
+  ListJobRunAttemptsCommandInput,
+  ListJobRunAttemptsCommandOutput
+>(EMRServerlessClient, ListJobRunAttemptsCommand, "nextToken", "nextToken", "maxResults");

clients/client-emr-serverless/src/pagination/index.ts

@@ -1,4 +1,5 @@
 // smithy-typescript generated code
 export * from "./Interfaces";
 export * from "./ListApplicationsPaginator";
+export * from "./ListJobRunAttemptsPaginator";
 export * from "./ListJobRunsPaginator";

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

@@ -43,6 +43,7 @@ import {
 } from "../commands/GetDashboardForJobRunCommand";
 import { GetJobRunCommandInput, GetJobRunCommandOutput } from "../commands/GetJobRunCommand";
 import { ListApplicationsCommandInput, ListApplicationsCommandOutput } from "../commands/ListApplicationsCommand";
+import { ListJobRunAttemptsCommandInput, ListJobRunAttemptsCommandOutput } from "../commands/ListJobRunAttemptsCommand";
 import { ListJobRunsCommandInput, ListJobRunsCommandOutput } from "../commands/ListJobRunsCommand";
 import {
   ListTagsForResourceCommandInput,
@@ -71,6 +72,7 @@ import {
   InternalServerException,
   JobDriver,
   JobRun,
+  JobRunAttemptSummary,
   JobRunSummary,
   ManagedPersistenceMonitoringConfiguration,
   MaximumAllowedResources,
@@ -79,6 +81,7 @@ import {
   PrometheusMonitoringConfiguration,
   ResourceNotFoundException,
   ResourceUtilization,
+  RetryPolicy,
   S3MonitoringConfiguration,
   ServiceQuotaExceededException,
   SparkSubmit,
@@ -186,8 +189,11 @@ export const se_GetDashboardForJobRunCommand = async (
   b.bp("/applications/{applicationId}/jobruns/{jobRunId}/dashboard");
   b.p("applicationId", () => input.applicationId!, "{applicationId}", false);
   b.p("jobRunId", () => input.jobRunId!, "{jobRunId}", false);
+  const query: any = map({
+    [_a]: [() => input.attempt !== void 0, () => input[_a]!.toString()],
+  });
   let body: any;
-  b.m("GET").h(headers).b(body);
+  b.m("GET").h(headers).q(query).b(body);
   return b.build();
 };
 
@@ -203,8 +209,11 @@ export const se_GetJobRunCommand = 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({
+    [_a]: [() => input.attempt !== void 0, () => input[_a]!.toString()],
+  });
   let body: any;
-  b.m("GET").h(headers).b(body);
+  b.m("GET").h(headers).q(query).b(body);
   return b.build();
 };
 
@@ -228,6 +237,27 @@ export const se_ListApplicationsCommand = async (
   return b.build();
 };
 
+/**
+ * serializeAws_restJson1ListJobRunAttemptsCommand
+ */
+export const se_ListJobRunAttemptsCommand = async (
+  input: ListJobRunAttemptsCommandInput,
+  context: __SerdeContext
+): Promise<__HttpRequest> => {
+  const b = rb(input, context);
+  const headers: any = {};
+  b.bp("/applications/{applicationId}/jobruns/{jobRunId}/attempts");
+  b.p("applicationId", () => input.applicationId!, "{applicationId}", false);
+  b.p("jobRunId", () => input.jobRunId!, "{jobRunId}", false);
+  const query: any = map({
+    [_nT]: [, input[_nT]!],
+    [_mR]: [() => input.maxResults !== void 0, () => input[_mR]!.toString()],
+  });
+  let body: any;
+  b.m("GET").h(headers).q(query).b(body);
+  return b.build();
+};
+
 /**
  * serializeAws_restJson1ListJobRunsCommand
  */
@@ -245,6 +275,7 @@ export const se_ListJobRunsCommand = async (
     [_cAA]: [() => input.createdAtAfter !== void 0, () => __serializeDateTime(input[_cAA]!).toString()],
     [_cAB]: [() => input.createdAtBefore !== void 0, () => __serializeDateTime(input[_cAB]!).toString()],
     [_s]: [() => input.states !== void 0, () => (input[_s]! || []).map((_entry) => _entry as any)],
+    [_m]: [, input[_m]!],
   });
   let body: any;
   b.m("GET").h(headers).q(query).b(body);
@@ -304,7 +335,9 @@ export const se_StartJobRunCommand = async (
       executionRoleArn: [],
       executionTimeoutMinutes: [],
       jobDriver: (_) => _json(_),
+      mode: [],
       name: [],
+      retryPolicy: (_) => _json(_),
       tags: (_) => _json(_),
     })
   );
@@ -555,6 +588,28 @@ export const de_ListApplicationsCommand = async (
   return contents;
 };
 
+/**
+ * deserializeAws_restJson1ListJobRunAttemptsCommand
+ */
+export const de_ListJobRunAttemptsCommand = async (
+  output: __HttpResponse,
+  context: __SerdeContext
+): Promise<ListJobRunAttemptsCommandOutput> => {
+  if (output.statusCode !== 200 && output.statusCode >= 300) {
+    return de_CommandError(output, context);
+  }
+  const contents: any = map({
+    $metadata: deserializeMetadata(output),
+  });
+  const data: Record<string, any> = __expectNonNull(__expectObject(await parseBody(output.body, context)), "body");
+  const doc = take(data, {
+    jobRunAttempts: (_) => de_JobRunAttempts(_, context),
+    nextToken: __expectString,
+  });
+  Object.assign(contents, doc);
+  return contents;
+};
+
 /**
  * deserializeAws_restJson1ListJobRunsCommand
  */
@@ -906,6 +961,8 @@ const se_ConfigurationOverrides = (input: ConfigurationOverrides, context: __Ser
 
 // se_PrometheusMonitoringConfiguration omitted.
 
+// se_RetryPolicy omitted.
+
 // se_S3MonitoringConfiguration omitted.
 
 // se_SecurityGroupIds omitted.
@@ -1043,6 +1100,9 @@ const de_JobRun = (output: any, context: __SerdeContext): JobRun => {
   return take(output, {
     applicationId: __expectString,
     arn: __expectString,
+    attempt: __expectInt32,
+    attemptCreatedAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
+    attemptUpdatedAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
     billedResourceUtilization: (_: any) => de_ResourceUtilization(_, context),
     configurationOverrides: (_: any) => de_ConfigurationOverrides(_, context),
     createdAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
@@ -1051,9 +1111,11 @@ const de_JobRun = (output: any, context: __SerdeContext): JobRun => {
     executionTimeoutMinutes: __expectLong,
     jobDriver: (_: any) => _json(__expectUnion(_)),
     jobRunId: __expectString,
+    mode: __expectString,
     name: __expectString,
     networkConfiguration: _json,
     releaseLabel: __expectString,
+    retryPolicy: _json,
     state: __expectString,
     stateDetails: __expectString,
     tags: _json,
@@ -1063,6 +1125,41 @@ const de_JobRun = (output: any, context: __SerdeContext): JobRun => {
   }) as any;
 };
 
+/**
+ * deserializeAws_restJson1JobRunAttempts
+ */
+const de_JobRunAttempts = (output: any, context: __SerdeContext): JobRunAttemptSummary[] => {
+  const retVal = (output || [])
+    .filter((e: any) => e != null)
+    .map((entry: any) => {
+      return de_JobRunAttemptSummary(entry, context);
+    });
+  return retVal;
+};
+
+/**
+ * deserializeAws_restJson1JobRunAttemptSummary
+ */
+const de_JobRunAttemptSummary = (output: any, context: __SerdeContext): JobRunAttemptSummary => {
+  return take(output, {
+    applicationId: __expectString,
+    arn: __expectString,
+    attempt: __expectInt32,
+    createdAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
+    createdBy: __expectString,
+    executionRole: __expectString,
+    id: __expectString,
+    jobCreatedAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
+    mode: __expectString,
+    name: __expectString,
+    releaseLabel: __expectString,
+    state: __expectString,
+    stateDetails: __expectString,
+    type: __expectString,
+    updatedAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
+  }) as any;
+};
+
 /**
  * deserializeAws_restJson1JobRuns
  */
@@ -1082,10 +1179,14 @@ const de_JobRunSummary = (output: any, context: __SerdeContext): JobRunSummary =
   return take(output, {
     applicationId: __expectString,
     arn: __expectString,
+    attempt: __expectInt32,
+    attemptCreatedAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
+    attemptUpdatedAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
     createdAt: (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))),
     createdBy: __expectString,
     executionRole: __expectString,
     id: __expectString,
+    mode: __expectString,
     name: __expectString,
     releaseLabel: __expectString,
     state: __expectString,
@@ -1120,6 +1221,8 @@ const de_ResourceUtilization = (output: any, context: __SerdeContext): ResourceU
   }) as any;
 };
 
+// de_RetryPolicy omitted.
+
 // de_S3MonitoringConfiguration omitted.
 
 // de_SecurityGroupIds omitted.
@@ -1168,8 +1271,10 @@ const isSerializableHeaderValue = (value: any): boolean =>
   (!Object.getOwnPropertyNames(value).includes("length") || value.length != 0) &&
   (!Object.getOwnPropertyNames(value).includes("size") || value.size != 0);
 
+const _a = "attempt";
 const _cAA = "createdAtAfter";
 const _cAB = "createdAtBefore";
+const _m = "mode";
 const _mR = "maxResults";
 const _nT = "nextToken";
 const _s = "states";