core/oc-lib
5
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

kick out print

Browse Source
This commit is contained in:
mr 2024-08-05 08:50:20 +02:00
parent e390dfa8a9
commit 1e8cb98098
2 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dbs/mongo/mongo.go
View File

@ -3,7 +3,6 @@ package mongo
import ( import (
"context" "context"
"errors" "errors"
"fmt"
"time" "time"
"cloud.o-forge.io/core/oc-lib/dbs" "cloud.o-forge.io/core/oc-lib/dbs"
@ -290,7 +289,6 @@ func (m *MongoDB) Search(filters *dbs.Filters, collection_name string) (*mongo.C
MngoCtx, cancel = context.WithTimeout(context.Background(), 10*time.Second) MngoCtx, cancel = context.WithTimeout(context.Background(), 10*time.Second)
defer cancel() defer cancel()
fmt.Printf("Filter: %v %v %v\n", f, filters, filters.And)
if cursor, err := targetDBCollection.Find( if cursor, err := targetDBCollection.Find(
MngoCtx, MngoCtx,
f, f,

2
models/workflow/workflow_mongo_accessor.go
View File

@ -2,7 +2,6 @@ package oclib
import ( import (
"errors" "errors"
"fmt"
"cloud.o-forge.io/core/oc-lib/dbs" "cloud.o-forge.io/core/oc-lib/dbs"
"cloud.o-forge.io/core/oc-lib/dbs/mongo" "cloud.o-forge.io/core/oc-lib/dbs/mongo"
@ -115,7 +114,6 @@ func (wfa *workflowMongoAccessor) execute(workflow *Workflow) {
} }
resource, _, err := accessor.Search(filters, "") resource, _, err := accessor.Search(filters, "")
if err == nil && len(resource) > 0 { if err == nil && len(resource) > 0 {
fmt.Println(workflow.Serialize(), resource[0].GetID())
accessor.UpdateOne(&workspace.Workspace{ accessor.UpdateOne(&workspace.Workspace{
Active: true, Active: true,
ResourceSet: resources.ResourceSet{ ResourceSet: resources.ResourceSet{