You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by wa...@apache.org on 2022/06/15 07:56:33 UTC
[incubator-devlake] 06/12: append
This is an automated email from the ASF dual-hosted git repository.
warren pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
commit a0e4a352a1a277eaddb34a62b53ddaea4f3da96c
Author: linyh <ya...@meri.co>
AuthorDate: Wed Jun 15 12:25:04 2022 +0800
append
---
helpers/e2ehelper/data_flow_tester.go | 8 --------
1 file changed, 8 deletions(-)
diff --git a/helpers/e2ehelper/data_flow_tester.go b/helpers/e2ehelper/data_flow_tester.go
index ccd32fb9..d8fc8585 100644
--- a/helpers/e2ehelper/data_flow_tester.go
+++ b/helpers/e2ehelper/data_flow_tester.go
@@ -123,10 +123,6 @@ func (t *DataFlowTester) FlushRawTable(rawTableName string) {
if err != nil {
panic(err)
}
- err = t.Db.Exec(fmt.Sprintf("DELETE FROM %s", rawTableName)).Error
- if err != nil {
- panic(err)
- }
}
// FlushTabler migrate table and deletes all records from specified table
@@ -140,10 +136,6 @@ func (t *DataFlowTester) FlushTabler(dst schema.Tabler) {
if err != nil {
panic(err)
}
- err = t.Db.Delete(dst, `true`).Error
- if err != nil {
- panic(err)
- }
}
// Subtask executes specified subtasks