Refactoring Cassandra workflow persistence manager for NoSQL support-…

…Part 3
cadence-workflow · Jul 9, 2021 · 572582c · 572582c
1 parent c185ad8
commit 572582c
Show file tree

Hide file tree

Showing 11 changed files with 2,575 additions and 2,749 deletions.
diff --git a/common/persistence/cassandra/cassandraPersistence.go b/common/persistence/cassandra/cassandraPersistence.go
diff --git a/common/persistence/nosql/factory.go b/common/persistence/nosql/factory.go
@@ -27,8 +27,6 @@ import (
 	"github.com/uber/cadence/common/log"
 	p "github.com/uber/cadence/common/persistence"
 
-	// NOTE: this package will be refactored and removed soon
-	cassandraOld "github.com/uber/cadence/common/persistence/cassandra"
 	"github.com/uber/cadence/common/persistence/nosql/nosqlplugin/cassandra"
 	"github.com/uber/cadence/common/persistence/nosql/nosqlplugin/cassandra/gocql"
 )
@@ -152,7 +150,7 @@ func (f *executionStoreFactory) close() {
 
 // new implements ExecutionStoreFactory interface
 func (f *executionStoreFactory) new(shardID int) (p.ExecutionStore, error) {
-	pmgr, err := cassandraOld.NewWorkflowExecutionPersistence(shardID, f.client, f.session, f.logger)
+	pmgr, err := NewExecutionStore(shardID, f.client, f.session, f.logger)
 	if err != nil {
 		return nil, err
 	}