fix: fixed subscriber startTime issue (#4087)

Signed-off-by: Amit Kumar Das <amit.das@harness.io>
litmuschaos · Jul 13, 2023 · b0ba3fa · b0ba3fa
1 parent 351d0ba
commit b0ba3fa
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/chaoscenter/subscriber/pkg/events/chaosengine.go b/chaoscenter/subscriber/pkg/events/chaosengine.go
@@ -83,7 +83,7 @@ func chaosEventHandler(obj interface{}, eventType string, stream chan types.Work
 		return
 	}
 
-	if workflowObj.ObjectMeta.CreationTimestamp.Unix() < startTime {
+	if workflowObj.ObjectMeta.CreationTimestamp.UnixMilli() < startTime {
 		return
 	}
 

diff --git a/chaoscenter/subscriber/pkg/events/workflow.go b/chaoscenter/subscriber/pkg/events/workflow.go
@@ -111,8 +111,8 @@ func WorkflowEventHandler(workflowObj *v1alpha1.Workflow, eventType string, star
 		return types.WorkflowEvent{}, nil
 	}
 
-	if workflowObj.ObjectMeta.CreationTimestamp.Unix() < startTime {
-		return types.WorkflowEvent{}, nil
+	if workflowObj.ObjectMeta.CreationTimestamp.UnixMilli() < startTime {
+		return types.WorkflowEvent{}, errors.New("startTime of subscriber is greater than experiment creation timestamp")
 	}
 
 	cfg, err := k8s.GetKubeConfig()