Open Record Fix: write open record when workflow starts (cadence-work…

…flow#1669) * Write open record when workflow start * Add execution time to visibility * Write start event to cache in ReplicateWorkflowExecutionStartedEvent
zshni · Apr 9, 2019 · 0bd9676 · 0bd9676
1 parent af7d7ee
commit 0bd9676
Show file tree

Hide file tree

Showing 46 changed files with 826 additions and 306 deletions.
diff --git a/.gen/go/shared/idl.go b/.gen/go/shared/idl.go
diff --git a/.gen/go/shared/types.go b/.gen/go/shared/types.go
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/common/cron/cron.go b/common/cron/cron.go
@@ -59,3 +59,13 @@ func GetBackoffForNextSchedule(cronSchedule string, nowTime time.Time) time.Dura
 	roundedInterval := time.Second * time.Duration(math.Ceil(backoffInterval.Seconds()))
 	return roundedInterval
 }
+
+// GetBackoffForNextScheduleInSeconds calculates the backoff time in seconds for the
+// next run given a cronSchedule and current time
+func GetBackoffForNextScheduleInSeconds(cronSchedule string, nowTime time.Time) int32 {
+	backoffDuration := GetBackoffForNextSchedule(cronSchedule, nowTime)
+	if backoffDuration == NoBackoff {
+		return 0
+	}
+	return int32(math.Ceil(backoffDuration.Seconds()))
+}
diff --git a/common/elasticsearch/defs.go b/common/elasticsearch/defs.go
@@ -29,6 +29,7 @@ const (
 	RunID         = "RunID"
 	WorkflowType  = "WorkflowType"
 	StartTime     = "StartTime"
+	ExecutionTime = "ExecutionTime"
 	CloseTime     = "CloseTime"
 	CloseStatus   = "CloseStatus"
 	HistoryLength = "HistoryLength"
@@ -50,6 +51,7 @@ var (
 		RunID:         struct{}{},
 		WorkflowType:  struct{}{},
 		StartTime:     struct{}{},
+		ExecutionTime: struct{}{},
 		CloseTime:     struct{}{},
 		CloseStatus:   struct{}{},
 		HistoryLength: struct{}{},