Refactoring Cassandra task persistence manager for NoSQL support

jenna-dd · Jun 2, 2021 · 723ecf5 · 723ecf5
1 parent b660112
commit 723ecf5
Show file tree

Hide file tree

Showing 11 changed files with 905 additions and 427 deletions.
diff --git a/common/persistence/cassandra/cassandraPersistence.go b/common/persistence/cassandra/cassandraPersistence.go
@@ -90,7 +90,7 @@ const (
 	rowTypeShardTaskID     = int64(-11)
 	emptyInitiatedID       = int64(-7)
 
-	stickyTaskListTTL = int32(24 * time.Hour / time.Second) // if sticky task_list stopped being updated, remove it in one day
+	stickyTaskListTTL = int64(24 * time.Hour / time.Second) // if sticky task_list stopped being updated, remove it in one day
 )
 
 const (

diff --git a/common/persistence/cassandra/cassandraPersistenceUtil.go b/common/persistence/cassandra/cassandraPersistenceUtil.go
@@ -2131,29 +2131,6 @@ func createHistoryEventBatchBlob(
 	return eventBatch
 }
 
-func createTaskInfo(
-	result map[string]interface{},
-) *p.InternalTaskInfo {
-
-	info := &p.InternalTaskInfo{}
-	for k, v := range result {
-		switch k {
-		case "domain_id":
-			info.DomainID = v.(gocql.UUID).String()
-		case "workflow_id":
-			info.WorkflowID = v.(string)
-		case "run_id":
-			info.RunID = v.(gocql.UUID).String()
-		case "schedule_id":
-			info.ScheduleID = v.(int64)
-		case "created_time":
-			info.CreatedTime = v.(time.Time)
-		}
-	}
-
-	return info
-}
-
 func createTimerTaskInfo(
 	result map[string]interface{},
 ) *p.TimerTaskInfo {