Skip to content

Commit 3e06157

Browse files
author
awstools
committed
feat(client-mediaconvert): This release adds the ability to reconfigure concurrent job settings for existing queues and create queues with custom concurrent job settings.
1 parent d9ff29d commit 3e06157

File tree

7 files changed

+221
-0
lines changed

7 files changed

+221
-0
lines changed

‎clients/client-mediaconvert/src/commands/CreateQueueCommand.ts

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ export interface CreateQueueCommandOutput extends CreateQueueResponse, __Metadat
3636
* // const { MediaConvertClient, CreateQueueCommand } = require("@aws-sdk/client-mediaconvert"); // CommonJS import
3737
* const client = new MediaConvertClient(config);
3838
* const input = { // CreateQueueRequest
39+
* ConcurrentJobs: Number("int"),
3940
* Description: "STRING_VALUE",
4041
* Name: "STRING_VALUE", // required
4142
* PricingPlan: "ON_DEMAND" || "RESERVED",
@@ -54,6 +55,7 @@ export interface CreateQueueCommandOutput extends CreateQueueResponse, __Metadat
5455
* // { // CreateQueueResponse
5556
* // Queue: { // Queue
5657
* // Arn: "STRING_VALUE",
58+
* // ConcurrentJobs: Number("int"),
5759
* // CreatedAt: new Date("TIMESTAMP"),
5860
* // Description: "STRING_VALUE",
5961
* // LastUpdated: new Date("TIMESTAMP"),
@@ -68,6 +70,14 @@ export interface CreateQueueCommandOutput extends CreateQueueResponse, __Metadat
6870
* // ReservedSlots: Number("int"),
6971
* // Status: "ACTIVE" || "EXPIRED",
7072
* // },
73+
* // ServiceOverrides: [ // __listOfServiceOverride
74+
* // { // ServiceOverride
75+
* // Message: "STRING_VALUE",
76+
* // Name: "STRING_VALUE",
77+
* // OverrideValue: "STRING_VALUE",
78+
* // Value: "STRING_VALUE",
79+
* // },
80+
* // ],
7181
* // Status: "ACTIVE" || "PAUSED",
7282
* // SubmittedJobsCount: Number("int"),
7383
* // Type: "SYSTEM" || "CUSTOM",

‎clients/client-mediaconvert/src/commands/GetQueueCommand.ts

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ export interface GetQueueCommandOutput extends GetQueueResponse, __MetadataBeare
4343
* // { // GetQueueResponse
4444
* // Queue: { // Queue
4545
* // Arn: "STRING_VALUE",
46+
* // ConcurrentJobs: Number("int"),
4647
* // CreatedAt: new Date("TIMESTAMP"),
4748
* // Description: "STRING_VALUE",
4849
* // LastUpdated: new Date("TIMESTAMP"),
@@ -57,6 +58,14 @@ export interface GetQueueCommandOutput extends GetQueueResponse, __MetadataBeare
5758
* // ReservedSlots: Number("int"),
5859
* // Status: "ACTIVE" || "EXPIRED",
5960
* // },
61+
* // ServiceOverrides: [ // __listOfServiceOverride
62+
* // { // ServiceOverride
63+
* // Message: "STRING_VALUE",
64+
* // Name: "STRING_VALUE",
65+
* // OverrideValue: "STRING_VALUE",
66+
* // Value: "STRING_VALUE",
67+
* // },
68+
* // ],
6069
* // Status: "ACTIVE" || "PAUSED",
6170
* // SubmittedJobsCount: Number("int"),
6271
* // Type: "SYSTEM" || "CUSTOM",

‎clients/client-mediaconvert/src/commands/ListQueuesCommand.ts

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ export interface ListQueuesCommandOutput extends ListQueuesResponse, __MetadataB
4848
* // Queues: [ // __listOfQueue
4949
* // { // Queue
5050
* // Arn: "STRING_VALUE",
51+
* // ConcurrentJobs: Number("int"),
5152
* // CreatedAt: new Date("TIMESTAMP"),
5253
* // Description: "STRING_VALUE",
5354
* // LastUpdated: new Date("TIMESTAMP"),
@@ -62,11 +63,21 @@ export interface ListQueuesCommandOutput extends ListQueuesResponse, __MetadataB
6263
* // ReservedSlots: Number("int"),
6364
* // Status: "ACTIVE" || "EXPIRED",
6465
* // },
66+
* // ServiceOverrides: [ // __listOfServiceOverride
67+
* // { // ServiceOverride
68+
* // Message: "STRING_VALUE",
69+
* // Name: "STRING_VALUE",
70+
* // OverrideValue: "STRING_VALUE",
71+
* // Value: "STRING_VALUE",
72+
* // },
73+
* // ],
6574
* // Status: "ACTIVE" || "PAUSED",
6675
* // SubmittedJobsCount: Number("int"),
6776
* // Type: "SYSTEM" || "CUSTOM",
6877
* // },
6978
* // ],
79+
* // TotalConcurrentJobs: Number("int"),
80+
* // UnallocatedConcurrentJobs: Number("int"),
7081
* // };
7182
*
7283
* ```

‎clients/client-mediaconvert/src/commands/UpdateQueueCommand.ts

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ export interface UpdateQueueCommandOutput extends UpdateQueueResponse, __Metadat
3636
* // const { MediaConvertClient, UpdateQueueCommand } = require("@aws-sdk/client-mediaconvert"); // CommonJS import
3737
* const client = new MediaConvertClient(config);
3838
* const input = { // UpdateQueueRequest
39+
* ConcurrentJobs: Number("int"),
3940
* Description: "STRING_VALUE",
4041
* Name: "STRING_VALUE", // required
4142
* ReservationPlanSettings: { // ReservationPlanSettings
@@ -50,6 +51,7 @@ export interface UpdateQueueCommandOutput extends UpdateQueueResponse, __Metadat
5051
* // { // UpdateQueueResponse
5152
* // Queue: { // Queue
5253
* // Arn: "STRING_VALUE",
54+
* // ConcurrentJobs: Number("int"),
5355
* // CreatedAt: new Date("TIMESTAMP"),
5456
* // Description: "STRING_VALUE",
5557
* // LastUpdated: new Date("TIMESTAMP"),
@@ -64,6 +66,14 @@ export interface UpdateQueueCommandOutput extends UpdateQueueResponse, __Metadat
6466
* // ReservedSlots: Number("int"),
6567
* // Status: "ACTIVE" || "EXPIRED",
6668
* // },
69+
* // ServiceOverrides: [ // __listOfServiceOverride
70+
* // { // ServiceOverride
71+
* // Message: "STRING_VALUE",
72+
* // Name: "STRING_VALUE",
73+
* // OverrideValue: "STRING_VALUE",
74+
* // Value: "STRING_VALUE",
75+
* // },
76+
* // ],
6777
* // Status: "ACTIVE" || "PAUSED",
6878
* // SubmittedJobsCount: Number("int"),
6979
* // Type: "SYSTEM" || "CUSTOM",

‎clients/client-mediaconvert/src/models/models_2.ts

Lines changed: 66 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,36 @@ export interface ReservationPlan {
6565
Status?: ReservationPlanStatus | undefined;
6666
}
6767

68+
/**
69+
* A service override applied by MediaConvert to the settings that you have configured. If you see any overrides, we recommend that you contact AWS Support.
70+
* @public
71+
*/
72+
export interface ServiceOverride {
73+
/**
74+
* Details about the service override that MediaConvert has applied.
75+
* @public
76+
*/
77+
Message?: string | undefined;
78+
79+
/**
80+
* The name of the setting that MediaConvert has applied an override to.
81+
* @public
82+
*/
83+
Name?: string | undefined;
84+
85+
/**
86+
* The current value of the service override that MediaConvert has applied.
87+
* @public
88+
*/
89+
OverrideValue?: string | undefined;
90+
91+
/**
92+
* The value of the setting that you configured, prior to any overrides that MediaConvert has applied.
93+
* @public
94+
*/
95+
Value?: string | undefined;
96+
}
97+
6898
/**
6999
* @public
70100
* @enum
@@ -90,6 +120,12 @@ export interface Queue {
90120
*/
91121
Arn?: string | undefined;
92122

123+
/**
124+
* The maximum number of jobs your queue can process concurrently.
125+
* @public
126+
*/
127+
ConcurrentJobs?: number | undefined;
128+
93129
/**
94130
* The timestamp in epoch seconds for when you created the queue.
95131
* @public
@@ -132,6 +168,12 @@ export interface Queue {
132168
*/
133169
ReservationPlan?: ReservationPlan | undefined;
134170

171+
/**
172+
* A list of any service overrides applied by MediaConvert to the settings that you have configured. If you see any overrides, we recommend that you contact AWS Support.
173+
* @public
174+
*/
175+
ServiceOverrides?: ServiceOverride[] | undefined;
176+
135177
/**
136178
* Queues can be ACTIVE or PAUSED. If you pause a queue, the service won't begin processing jobs in that queue. Jobs that are running when you pause the queue continue to run until they finish or result in an error.
137179
* @public
@@ -565,6 +607,12 @@ export interface ReservationPlanSettings {
565607
* @public
566608
*/
567609
export interface CreateQueueRequest {
610+
/**
611+
* Specify the maximum number of jobs your queue can process concurrently. For on-demand queues, the value you enter is constrained by your service quotas for Maximum concurrent jobs, per on-demand queue and Maximum concurrent jobs, per account. For reserved queues, specify the number of jobs you can process concurrently in your reservation plan instead.
612+
* @public
613+
*/
614+
ConcurrentJobs?: number | undefined;
615+
568616
/**
569617
* Optional. A description of the queue that you are creating.
570618
* @public
@@ -1143,6 +1191,18 @@ export interface ListQueuesResponse {
11431191
* @public
11441192
*/
11451193
Queues?: Queue[] | undefined;
1194+
1195+
/**
1196+
* The maximum number of jobs that MediaConvert can process at one time, across all of your on-demand queues in the current AWS Region.
1197+
* @public
1198+
*/
1199+
TotalConcurrentJobs?: number | undefined;
1200+
1201+
/**
1202+
* The remaining number of concurrent jobs that are not associated with a queue and are available to allocate to a queue. You can allocate these jobs when you create or update a queue.
1203+
* @public
1204+
*/
1205+
UnallocatedConcurrentJobs?: number | undefined;
11461206
}
11471207

11481208
/**
@@ -1457,6 +1517,12 @@ export interface UpdatePresetResponse {
14571517
* @public
14581518
*/
14591519
export interface UpdateQueueRequest {
1520+
/**
1521+
* Specify the maximum number of jobs your queue can process concurrently. For on-demand queues, the value you enter is constrained by your service quotas for Maximum concurrent jobs, per on-demand queue and Maximum concurrent jobs, per account. For reserved queues, update your reservation plan instead in order to increase your yearly commitment.
1522+
* @public
1523+
*/
1524+
ConcurrentJobs?: number | undefined;
1525+
14601526
/**
14611527
* The new description for the queue, if you are changing it.
14621528
* @public

‎clients/client-mediaconvert/src/protocols/Aws_restJson1.ts

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -265,6 +265,7 @@ import {
265265
ReservationPlan,
266266
ReservationPlanSettings,
267267
ResourceTags,
268+
ServiceOverride,
268269
TooManyRequestsException,
269270
} from "../models/models_2";
270271

@@ -413,6 +414,7 @@ export const se_CreateQueueCommand = async (
413414
let body: any;
414415
body = JSON.stringify(
415416
take(input, {
417+
concurrentJobs: [, , `ConcurrentJobs`],
416418
description: [, , `Description`],
417419
name: [, , `Name`],
418420
pricingPlan: [, , `PricingPlan`],
@@ -888,6 +890,7 @@ export const se_UpdateQueueCommand = async (
888890
let body: any;
889891
body = JSON.stringify(
890892
take(input, {
893+
concurrentJobs: [, , `ConcurrentJobs`],
891894
description: [, , `Description`],
892895
reservationPlanSettings: [, (_) => se_ReservationPlanSettings(_, context), `ReservationPlanSettings`],
893896
status: [, , `Status`],
@@ -1310,6 +1313,8 @@ export const de_ListQueuesCommand = async (
13101313
const doc = take(data, {
13111314
NextToken: [, __expectString, `nextToken`],
13121315
Queues: [, (_) => de___listOfQueue(_, context), `queues`],
1316+
TotalConcurrentJobs: [, __expectInt32, `totalConcurrentJobs`],
1317+
UnallocatedConcurrentJobs: [, __expectInt32, `unallocatedConcurrentJobs`],
13131318
});
13141319
Object.assign(contents, doc);
13151320
return contents;
@@ -4941,6 +4946,18 @@ const de___listOfQueueTransition = (output: any, context: __SerdeContext): Queue
49414946
return retVal;
49424947
};
49434948

4949+
/**
4950+
* deserializeAws_restJson1__listOfServiceOverride
4951+
*/
4952+
const de___listOfServiceOverride = (output: any, context: __SerdeContext): ServiceOverride[] => {
4953+
const retVal = (output || [])
4954+
.filter((e: any) => e != null)
4955+
.map((entry: any) => {
4956+
return de_ServiceOverride(entry, context);
4957+
});
4958+
return retVal;
4959+
};
4960+
49444961
// de___listOfTeletextPageType omitted.
49454962

49464963
/**
@@ -7202,13 +7219,15 @@ const de_ProresSettings = (output: any, context: __SerdeContext): ProresSettings
72027219
const de_Queue = (output: any, context: __SerdeContext): Queue => {
72037220
return take(output, {
72047221
Arn: [, __expectString, `arn`],
7222+
ConcurrentJobs: [, __expectInt32, `concurrentJobs`],
72057223
CreatedAt: [, (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))), `createdAt`],
72067224
Description: [, __expectString, `description`],
72077225
LastUpdated: [, (_: any) => __expectNonNull(__parseEpochTimestamp(__expectNumber(_))), `lastUpdated`],
72087226
Name: [, __expectString, `name`],
72097227
PricingPlan: [, __expectString, `pricingPlan`],
72107228
ProgressingJobsCount: [, __expectInt32, `progressingJobsCount`],
72117229
ReservationPlan: [, (_: any) => de_ReservationPlan(_, context), `reservationPlan`],
7230+
ServiceOverrides: [, (_: any) => de___listOfServiceOverride(_, context), `serviceOverrides`],
72127231
Status: [, __expectString, `status`],
72137232
SubmittedJobsCount: [, __expectInt32, `submittedJobsCount`],
72147233
Type: [, __expectString, `type`],
@@ -7315,6 +7334,18 @@ const de_SccDestinationSettings = (output: any, context: __SerdeContext): SccDes
73157334
}) as any;
73167335
};
73177336

7337+
/**
7338+
* deserializeAws_restJson1ServiceOverride
7339+
*/
7340+
const de_ServiceOverride = (output: any, context: __SerdeContext): ServiceOverride => {
7341+
return take(output, {
7342+
Message: [, __expectString, `message`],
7343+
Name: [, __expectString, `name`],
7344+
OverrideValue: [, __expectString, `overrideValue`],
7345+
Value: [, __expectString, `value`],
7346+
}) as any;
7347+
};
7348+
73187349
/**
73197350
* deserializeAws_restJson1SpekeKeyProvider
73207351
*/

0 commit comments

Comments
 (0)