Record the stoppedAt time when marking a workflow as done. (#93)

* Update WorkflowSummary model * make generate * Record the `stoppedAt` time when marking a workflow as done. * Just check for describeOutput.StopDate
Clever · Nov 16, 2017 · 9cad929 · 9cad929
1 parent d43dadd
commit 9cad929
Show file tree

Hide file tree

Showing 8 changed files with 171 additions and 234 deletions.
diff --git a/docs/definitions.md b/docs/definitions.md
@@ -227,6 +227,7 @@
 |**retryFor**  <br>*optional*|workflow-id of original workflow in case this is a retry|string|
 |**status**  <br>*optional*||[WorkflowStatus](#workflowstatus)|
 |**statusReason**  <br>*optional*||string|
+|**stoppedAt**  <br>*optional*||string (date-time)|
 |**workflowDefinition**  <br>*optional*||[WorkflowDefinition](#workflowdefinition)|
 
 
@@ -292,6 +293,7 @@
 |**retries**  <br>*optional*|workflow-id's of workflows created as retries for this workflow|< string > array|
 |**retryFor**  <br>*optional*|workflow-id of original workflow in case this is a retry|string|
 |**status**  <br>*optional*||[WorkflowStatus](#workflowstatus)|
+|**stoppedAt**  <br>*optional*||string (date-time)|
 |**workflowDefinition**  <br>*optional*||[WorkflowDefinition](#workflowdefinition)|
 
 

diff --git a/docs/overview.md b/docs/overview.md
@@ -7,7 +7,7 @@ Orchestrator for AWS Step Functions
 
 
 ### Version information
-*Version* : 0.6.9
+*Version* : 0.6.10
 
 
 ### URI scheme

diff --git a/executor/workflow_manager_sfn.go b/executor/workflow_manager_sfn.go
@@ -384,6 +384,9 @@ func (wm *SFNWorkflowManager) UpdateWorkflowSummary(workflow *models.Workflow) e
 	if *describeOutput.Status == sfn.ExecutionStatusTimedOut {
 		workflow.StatusReason = resources.StatusReasonWorkflowTimedOut
 	}
+	if describeOutput.StopDate != nil {
+		workflow.StoppedAt = strfmt.DateTime(aws.TimeValue(describeOutput.StopDate))
+	}
 	workflow.Output = aws.StringValue(describeOutput.Output) // use for error or success  (TODO: actually this is only sent for success)
 	return wm.store.UpdateWorkflow(*workflow)
 }

diff --git a/gen-go/client/mock_client.go b/gen-go/client/mock_client.go
diff --git a/gen-go/models/workflow_summary.go b/gen-go/models/workflow_summary.go
diff --git a/gen-go/server/mock_controller.go b/gen-go/server/mock_controller.go
diff --git a/gen-js/package.json b/gen-js/package.json
@@ -1,6 +1,6 @@
 {
   "name": "workflow-manager",
-  "version": "0.6.9",
+  "version": "0.6.10",
   "description": "Orchestrator for AWS Step Functions",
   "main": "index.js",
   "dependencies": {

diff --git a/swagger.yml b/swagger.yml
@@ -4,7 +4,7 @@ info:
   description: Orchestrator for AWS Step Functions
   # when changing the version here, make sure to
   # re-run `make generate` to generate clients and server
-  version: 0.6.9
+  version: 0.6.10
   x-npm-package: workflow-manager
 schemes:
   - http
@@ -393,6 +393,9 @@ definitions:
       createdAt:
         type: string
         format: date-time
+      stoppedAt:
+        type: string
+        format: date-time
       lastUpdated:
         type: string
         format: date-time