You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2023/01/11 01:47:14 UTC
[incubator-eventmesh] branch master updated: optimize workflow save dal logic
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 8d8b694cf optimize workflow save dal logic
new 2ea48a480 Merge pull request #2895 from walterlife/feature/optimize-workflow-save
8d8b694cf is described below
commit 8d8b694cf9a2dd70d5460b76cd562739bc7ca87d
Author: walterlife <wa...@gmail.com>
AuthorDate: Tue Jan 10 22:12:33 2023 +0800
optimize workflow save dal logic
---
eventmesh-workflow-go/internal/dal/workflow.go | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git a/eventmesh-workflow-go/internal/dal/workflow.go b/eventmesh-workflow-go/internal/dal/workflow.go
index ca138db5e..6067f49e8 100644
--- a/eventmesh-workflow-go/internal/dal/workflow.go
+++ b/eventmesh-workflow-go/internal/dal/workflow.go
@@ -275,15 +275,17 @@ func (w *workflowDALImpl) create(ctx context.Context, tx *gorm.DB, record *model
if r != nil {
return errors.New("workflow id already exists")
}
- record.WorkflowID = wf.ID
- record.WorkflowName = wf.Name
- record.Version = wf.Version
- record.Status = constants.NormalStatus
- record.CreateTime = time.Now()
- record.UpdateTime = time.Now()
+ var insertData = model.Workflow{}
+ insertData.WorkflowID = wf.ID
+ insertData.WorkflowName = wf.Name
+ insertData.Version = wf.Version
+ insertData.Definition = record.Definition
+ insertData.Status = constants.NormalStatus
+ insertData.CreateTime = time.Now()
+ insertData.UpdateTime = time.Now()
var handlers []func() error
handlers = append(handlers, func() error {
- return tx.Create(record).Error
+ return tx.Create(insertData).Error
})
tasks := w.buildTask(wf)
for _, task := range tasks {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org