fix test bug
diff --git a/dockertests/docker_test.go b/dockertests/docker_test.go index 87eff5d..0851a41 100644 --- a/dockertests/docker_test.go +++ b/dockertests/docker_test.go
@@ -121,7 +121,7 @@ It("should get data according to data scope", func(done Done) { tableName := "docker_test_b" targetTablename := "edgex_" + tableName - handler := &newTableHandler{ + handler := &newTableScopeHandler{ targetTablename: targetTablename, done: done, } @@ -141,6 +141,8 @@ Expect(err).Should(Succeed()) _, err = tx.Exec("ALTER TABLE edgex." + tableName + " replica identity full;") Expect(err).Should(Succeed()) + _, err = tx.Exec("INSERT INTO edgex." + tableName + " values ('three', 3, '" + clusterIdFromConfig + "');") + Expect(err).Should(Succeed()) tx.Commit() } @@ -302,6 +304,7 @@ func (n *newTableHandler) Handle(event apid.Event) { if s, ok := event.(*common.Snapshot); ok { + defer GinkgoRecover() sqliteDb, err := dataService.DBVersion(s.SnapshotInfo) Expect(err).Should(Succeed()) Expect(verifyTestTableExist(n.targetTablename, sqliteDb)).To(BeTrue()) @@ -333,6 +336,7 @@ func (n *newTableScopeHandler) Handle(event apid.Event) { if s, ok := event.(*common.Snapshot); ok { + defer GinkgoRecover() sqliteDb, err := dataService.DBVersion(s.SnapshotInfo) Expect(err).Should(Succeed()) verifyTestTableData(n.targetTablename, sqliteDb)