IWF-105: Update IDL

indeedeng · Nov 14, 2024 · 6f2395e · 6f2395e
1 parent 526a127
commit 6f2395e
Show file tree

Hide file tree

Showing 5 changed files with 60 additions and 30 deletions.
diff --git a/gen/iwfidl/api/openapi.yaml b/gen/iwfidl/api/openapi.yaml
@@ -3305,9 +3305,19 @@ components:
       type: object
     EventType:
       enum:
-      - WORKFLOW_START_EVENT
+      - STATE_EXECUTE_ATTEMPT_FAIL_EVENT
+      - STATE_EXECUTE_ATTEMPT_SUCC_EVENT
+      - STATE_EXECUTE_E2E_COMPLETE_EVENT
+      - STATE_EXECUTE_E2E_FAIL_EVENT
+      - STATE_EXECUTE_E2E_START_EVENT
+      - STATE_WAIT_UNTIL_ATTEMPT_FAIL_EVENT
+      - STATE_WAIT_UNTIL_ATTEMPT_SUCC_EVENT
+      - STATE_WAIT_UNTIL_E2E_COMPLETE_EVENT
+      - STATE_WAIT_UNTIL_E2E_FAIL_EVENT
+      - STATE_WAIT_UNTIL_E2E_START_EVENT
       - WORKFLOW_COMPLETE_EVENT
       - WORKFLOW_FAIL_EVENT
+      - WORKFLOW_START_EVENT
       type: string
     IwfEvent:
       properties:

diff --git a/gen/iwfidl/docs/EventType.md b/gen/iwfidl/docs/EventType.md
@@ -3,11 +3,31 @@
 ## Enum
 
 
-* `START_EVENT` (value: `"WORKFLOW_START_EVENT"`)
+* `STATE_EXECUTE_ATTEMPT_FAIL_EVENT` (value: `"STATE_EXECUTE_ATTEMPT_FAIL_EVENT"`)
 
-* `COMPLETE_EVENT` (value: `"WORKFLOW_COMPLETE_EVENT"`)
+* `STATE_EXECUTE_ATTEMPT_SUCC_EVENT` (value: `"STATE_EXECUTE_ATTEMPT_SUCC_EVENT"`)
 
-* `FAIL_EVENT` (value: `"WORKFLOW_FAIL_EVENT"`)
+* `STATE_EXECUTE_E2_E_COMPLETE_EVENT` (value: `"STATE_EXECUTE_E2E_COMPLETE_EVENT"`)
+
+* `STATE_EXECUTE_E2_E_FAIL_EVENT` (value: `"STATE_EXECUTE_E2E_FAIL_EVENT"`)
+
+* `STATE_EXECUTE_E2_E_START_EVENT` (value: `"STATE_EXECUTE_E2E_START_EVENT"`)
+
+* `STATE_WAIT_UNTIL_ATTEMPT_FAIL_EVENT` (value: `"STATE_WAIT_UNTIL_ATTEMPT_FAIL_EVENT"`)
+
+* `STATE_WAIT_UNTIL_ATTEMPT_SUCC_EVENT` (value: `"STATE_WAIT_UNTIL_ATTEMPT_SUCC_EVENT"`)
+
+* `STATE_WAIT_UNTIL_E2_E_COMPLETE_EVENT` (value: `"STATE_WAIT_UNTIL_E2E_COMPLETE_EVENT"`)
+
+* `STATE_WAIT_UNTIL_E2_E_FAIL_EVENT` (value: `"STATE_WAIT_UNTIL_E2E_FAIL_EVENT"`)
+
+* `STATE_WAIT_UNTIL_E2_E_START_EVENT` (value: `"STATE_WAIT_UNTIL_E2E_START_EVENT"`)
+
+* `WORKFLOW_COMPLETE_EVENT` (value: `"WORKFLOW_COMPLETE_EVENT"`)
+
+* `WORKFLOW_FAIL_EVENT` (value: `"WORKFLOW_FAIL_EVENT"`)
+
+* `WORKFLOW_START_EVENT` (value: `"WORKFLOW_START_EVENT"`)
 
 
 [[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)

diff --git a/gen/iwfidl/model_event_type.go b/gen/iwfidl/model_event_type.go
diff --git a/iwf-idl b/iwf-idl
diff --git a/service/api/service.go b/service/api/service.go
@@ -187,12 +187,6 @@ func (s *serviceImpl) ApiV1WorkflowStartPost(
 		}
 	} else {
 		s.logger.Info("Started workflow", tag.WorkflowID(req.WorkflowId), tag.WorkflowRunID(runId))
-		logevent.Log(iwfidl.IwfEvent{
-			EventType:     iwfidl.START_EVENT,
-			WorkflowType:  "",
-			WorkflowId:    "",
-			WorkflowRunId: "",
-		})
 	}
 
 	return &iwfidl.WorkflowStartResponse{
@@ -526,7 +520,7 @@ func (s *serviceImpl) doApiV1WorkflowGetPost(
 
 	if getErr == nil {
 		logevent.Log(iwfidl.IwfEvent{
-			EventType:     iwfidl.COMPLETE_EVENT,
+			EventType:     iwfidl.WORKFLOW_COMPLETE_EVENT,
 			WorkflowType:  "",
 			WorkflowId:    "",
 			WorkflowRunId: "",
@@ -570,13 +564,6 @@ func (s *serviceImpl) doApiV1WorkflowGetPost(
 			errMsgPtr = iwfidl.PtrString(errMsg)
 		}
 
-		logevent.Log(iwfidl.IwfEvent{
-			EventType:     iwfidl.FAIL_EVENT,
-			WorkflowType:  "",
-			WorkflowId:    "",
-			WorkflowRunId: "",
-		})
-
 		return &iwfidl.WorkflowGetResponse{
 			WorkflowRunId:  descResp.RunId,
 			WorkflowStatus: iwfidl.FAILED,
@@ -600,13 +587,6 @@ func (s *serviceImpl) doApiV1WorkflowGetPost(
 		}
 
 		if descResp.Status == iwfidl.FAILED {
-			logevent.Log(iwfidl.IwfEvent{
-				EventType:     iwfidl.FAIL_EVENT,
-				WorkflowType:  "",
-				WorkflowId:    "",
-				WorkflowRunId: "",
-			})
-
 			errMsg = "unknown workflow failure from interpreter implementation"
 			s.logger.Error(errMsg, tag.WorkflowID(req.GetWorkflowId()), tag.WorkflowRunID(descResp.RunId))
 		}