From a53e3c987d67ff391311f9f6c128f82a74859d66 Mon Sep 17 00:00:00 2001 From: mr Date: Wed, 28 Aug 2024 17:14:01 +0200 Subject: [PATCH] correct workflow problem --- models/resources/workflow/graph/graph.go | 2 +- models/workflow/workflow_mongo_accessor.go | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/models/resources/workflow/graph/graph.go b/models/resources/workflow/graph/graph.go index 3635c92..bf6b565 100644 --- a/models/resources/workflow/graph/graph.go +++ b/models/resources/workflow/graph/graph.go @@ -13,7 +13,7 @@ type GraphItem struct { Width float64 `bson:"width" json:"width" validate:"required"` Height float64 `bson:"height" json:"height" validate:"required"` Position Position `bson:"position" json:"position" validate:"required"` - resources.ItemResource + *resources.ItemResource } type GraphLink struct { diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index 0d46fd7..2237517 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -178,13 +178,13 @@ func (wfa *workflowMongoAccessor) UpdateOne(set utils.DBObject, id string) (util if code != 200 { return nil, 409, err } - new := set.(*Workflow) + //new := set.(*Workflow) avoid := set.(*Workflow).Schedule == nil || (res.(*Workflow).Schedule != nil && res.(*Workflow).ScheduleActive == set.(*Workflow).ScheduleActive && res.(*Workflow).Schedule.Start == set.(*Workflow).Schedule.Start && res.(*Workflow).Schedule.End == set.(*Workflow).Schedule.End && res.(*Workflow).Schedule.Cron == set.(*Workflow).Schedule.Cron) - for _, i := range new.Graph.Items { + /*for _, i := range new.Graph.Items { if i.Datacenter == nil && i.Processing == nil && i.Storage == nil && i.Workflow == nil && i.Data == nil { return nil, 422, errors.New("graph item should have at least one resource data is corrupted") } - } + }*/ res, code, err = wfa.GenericUpdateOne(set, id, wfa, &Workflow{}) if code != 200 { return nil, code, err @@ -199,12 +199,12 @@ func (wfa *workflowMongoAccessor) UpdateOne(set utils.DBObject, id string) (util } func (wfa *workflowMongoAccessor) StoreOne(data utils.DBObject) (utils.DBObject, int, error) { - new := data.(*Workflow) + /*new := data.(*Workflow) for _, i := range new.Graph.Items { if i.Datacenter == nil && i.Processing == nil && i.Storage == nil && i.Workflow == nil && i.Data == nil { return nil, 422, errors.New("graph item should have at least one resource data is corrupted") } - } + }*/ res, code, err := wfa.GenericStoreOne(data, wfa) if err != nil { return nil, code, err