Skip to content

Commit 3ccfc39

Browse files
author
awstools
committed
feat(client-mwaa): Amazon MWAA now lets you choose a worker replacement strategy when updating an environment. This release adds two worker replacement strategies: FORCED (default), which stops workers immediately, and GRACEFUL, which allows workers to finish current tasks before shutting down.
1 parent 542663c commit 3ccfc39

File tree

5 files changed

+220
-150
lines changed

5 files changed

+220
-150
lines changed

clients/client-mwaa/src/commands/GetEnvironmentCommand.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,7 @@ export interface GetEnvironmentCommandOutput extends GetEnvironmentOutput, __Met
107107
* // ErrorMessage: "STRING_VALUE",
108108
* // },
109109
* // Source: "STRING_VALUE",
110+
* // WorkerReplacementStrategy: "STRING_VALUE",
110111
* // },
111112
* // WeeklyMaintenanceWindowStart: "STRING_VALUE",
112113
* // Tags: { // TagMap

clients/client-mwaa/src/commands/UpdateEnvironmentCommand.ts

Lines changed: 20 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -42,25 +42,12 @@ export interface UpdateEnvironmentCommandOutput extends UpdateEnvironmentOutput,
4242
* const input = { // UpdateEnvironmentInput
4343
* Name: "STRING_VALUE", // required
4444
* ExecutionRoleArn: "STRING_VALUE",
45-
* AirflowVersion: "STRING_VALUE",
46-
* SourceBucketArn: "STRING_VALUE",
47-
* DagS3Path: "STRING_VALUE",
48-
* PluginsS3Path: "STRING_VALUE",
49-
* PluginsS3ObjectVersion: "STRING_VALUE",
50-
* RequirementsS3Path: "STRING_VALUE",
51-
* RequirementsS3ObjectVersion: "STRING_VALUE",
52-
* StartupScriptS3Path: "STRING_VALUE",
53-
* StartupScriptS3ObjectVersion: "STRING_VALUE",
5445
* AirflowConfigurationOptions: { // AirflowConfigurationOptions
5546
* "<keys>": "STRING_VALUE",
5647
* },
48+
* AirflowVersion: "STRING_VALUE",
49+
* DagS3Path: "STRING_VALUE",
5750
* EnvironmentClass: "STRING_VALUE",
58-
* MaxWorkers: Number("int"),
59-
* NetworkConfiguration: { // UpdateNetworkConfigurationInput
60-
* SecurityGroupIds: [ // SecurityGroupList // required
61-
* "STRING_VALUE",
62-
* ],
63-
* },
6451
* LoggingConfiguration: { // LoggingConfigurationInput
6552
* DagProcessingLogs: { // ModuleLoggingConfigurationInput
6653
* Enabled: true || false, // required
@@ -83,12 +70,26 @@ export interface UpdateEnvironmentCommandOutput extends UpdateEnvironmentOutput,
8370
* LogLevel: "STRING_VALUE", // required
8471
* },
8572
* },
86-
* WeeklyMaintenanceWindowStart: "STRING_VALUE",
87-
* WebserverAccessMode: "STRING_VALUE",
73+
* MaxWorkers: Number("int"),
8874
* MinWorkers: Number("int"),
89-
* Schedulers: Number("int"),
90-
* MinWebservers: Number("int"),
9175
* MaxWebservers: Number("int"),
76+
* MinWebservers: Number("int"),
77+
* WorkerReplacementStrategy: "STRING_VALUE",
78+
* NetworkConfiguration: { // UpdateNetworkConfigurationInput
79+
* SecurityGroupIds: [ // SecurityGroupList // required
80+
* "STRING_VALUE",
81+
* ],
82+
* },
83+
* PluginsS3Path: "STRING_VALUE",
84+
* PluginsS3ObjectVersion: "STRING_VALUE",
85+
* RequirementsS3Path: "STRING_VALUE",
86+
* RequirementsS3ObjectVersion: "STRING_VALUE",
87+
* Schedulers: Number("int"),
88+
* SourceBucketArn: "STRING_VALUE",
89+
* StartupScriptS3Path: "STRING_VALUE",
90+
* StartupScriptS3ObjectVersion: "STRING_VALUE",
91+
* WebserverAccessMode: "STRING_VALUE",
92+
* WeeklyMaintenanceWindowStart: "STRING_VALUE",
9293
* };
9394
* const command = new UpdateEnvironmentCommand(input);
9495
* const response = await client.send(command);

0 commit comments

Comments
 (0)