Merge pull request #29 from geekcell/linear-backoff

Use linear backoff on the SDK v3 Waiter due to failure rate for short…

Author: Ic3w0lf

README.md

@@ -104,6 +104,7 @@ Will pass the following command to the container on the AWS ECS Fargate task:
 | task-wait-until-stopped | Whether to wait for the task to stop before finishing the action. If set to false, the action will finish immediately after the task reaches the `RUNNING` state (fire and forget). | `false` | true |
 | task-start-max-wait-time | How long to wait for the task to start (i.e. reach the `RUNNING` state) in seconds. If the task does not start within this time, the pipeline will fail. | `false` | 120 |
 | task-stopped-max-wait-time | How long to wait for the task to stop (i.e. reach the `STOPPED` state) in seconds. The task will not be canceled after this time, the pipeline will just be marked as failed. | `false` | 300 |
+| task-check-state-delay | How long to wait between each AWS API call to check the current state of the task in seconds. This is useful to avoid running into AWS rate limits. **However**, setting this too high might cause the Action to miss the time-window your task is in the "RUNNING" state (if you task is very short lived) and can cause the action to fail. | `false` | 6 |
 <!-- action-docs-inputs -->
 
 <!-- action-docs-outputs -->

action.yml

@@ -81,6 +81,14 @@ inputs:
     required: false
     default: 300
 
+  task-check-state-delay:
+    description: >-
+      How long to wait between each AWS API call to check the current state of the task in seconds. This is useful to
+      avoid running into AWS rate limits. **However**, setting this too high might cause the Action to miss the time-window
+      your task is in the "RUNNING" state (if you task is very short lived) and can cause the action to fail.
+    required: false
+    default: 6
+
 outputs:
   task-arn:
     description: 'The full ARN for the task that was ran.'

dist/index.js

@@ -73927,6 +73927,7 @@ const main = async () => {
         const taskWaitUntilStopped = core.getBooleanInput('task-wait-until-stopped', {required: false});
         const taskStartMaxWaitTime = parseInt(core.getInput('task-start-max-wait-time', {required: false}));
         const taskStoppedMaxWaitTime = parseInt(core.getInput('task-stopped-max-wait-time', {required: false}));
+        const taskCheckStateDelay = parseInt(core.getInput('task-check-state-delay', {required: false}));
 
         // Build Task parameters
         const taskRequestParams = {
@@ -74008,6 +74009,8 @@ const main = async () => {
             await waitUntilTasksRunning({
                 client: ecs,
                 maxWaitTime: taskStartMaxWaitTime,
+                maxDelay: taskCheckStateDelay,
+                minDelay: taskCheckStateDelay,
             }, {cluster, tasks: [taskArn]});
         } catch (error) {
             core.setFailed(`Task did not start successfully. Error: ${error.name}. State: ${error.state}.`);
@@ -74079,6 +74082,8 @@ const main = async () => {
             await waitUntilTasksStopped({
                 client: ecs,
                 maxWaitTime: taskStoppedMaxWaitTime,
+                maxDelay: taskCheckStateDelay,
+                minDelay: taskCheckStateDelay,
             }, {
                 cluster,
                 tasks: [taskArn],

index.js

@@ -29,6 +29,7 @@ const main = async () => {
         const taskWaitUntilStopped = core.getBooleanInput('task-wait-until-stopped', {required: false});
         const taskStartMaxWaitTime = parseInt(core.getInput('task-start-max-wait-time', {required: false}));
         const taskStoppedMaxWaitTime = parseInt(core.getInput('task-stopped-max-wait-time', {required: false}));
+        const taskCheckStateDelay = parseInt(core.getInput('task-check-state-delay', {required: false}));
 
         // Build Task parameters
         const taskRequestParams = {
@@ -110,6 +111,8 @@ const main = async () => {
             await waitUntilTasksRunning({
                 client: ecs,
                 maxWaitTime: taskStartMaxWaitTime,
+                maxDelay: taskCheckStateDelay,
+                minDelay: taskCheckStateDelay,
             }, {cluster, tasks: [taskArn]});
         } catch (error) {
             core.setFailed(`Task did not start successfully. Error: ${error.name}. State: ${error.state}.`);
@@ -181,6 +184,8 @@ const main = async () => {
             await waitUntilTasksStopped({
                 client: ecs,
                 maxWaitTime: taskStoppedMaxWaitTime,
+                maxDelay: taskCheckStateDelay,
+                minDelay: taskCheckStateDelay,
             }, {
                 cluster,
                 tasks: [taskArn],