Skip to content

Commit c50cfb4

Browse files
committed
Fixed auth fields
1 parent 3bde5a6 commit c50cfb4

File tree

2 files changed

+234
-177
lines changed

2 files changed

+234
-177
lines changed

db-connector.go

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3282,7 +3282,7 @@ func GetWorkflow(ctx context.Context, id string) (*Workflow, error) {
32823282
} else if strings.Contains(err.Error(), `cannot load field`) {
32833283
// Due to form migration
32843284
if !strings.Contains(err.Error(), `input_markdown`) {
3285-
log.Printf("[ERROR] Error in workflow loading. Migrating workflow to new workflow handler (1): %s", err)
3285+
log.Printf("[ERROR] Error in workflow loading. Migrating workflow to new workflow handler (5): %s", err)
32863286
}
32873287

32883288
err = nil
@@ -3623,7 +3623,10 @@ func GetAllWorkflowsByQuery(ctx context.Context, user User, maxAmount int, curso
36233623

36243624
if err != nil {
36253625
if strings.Contains(fmt.Sprintf("%s", err), "cannot load field") {
3626-
log.Printf("[ERROR] Error in workflow loading. Migrating workflow query outputs to new workflow handler (1): %s", err)
3626+
3627+
if !strings.Contains(fmt.Sprintf("%s", err), "input_markdown") {
3628+
log.Printf("[ERROR] Error in workflow loading. Migrating workflow query outputs to new workflow handler (6): %s", err)
3629+
}
36273630
} else if strings.Contains(fmt.Sprintf("%s", err), "no more items in iterator") {
36283631
break
36293632
} else {
@@ -11823,7 +11826,7 @@ func GetCacheKey(ctx context.Context, id string) (*CacheKeyData, error) {
1182311826
if err := project.Dbclient.Get(ctx, key, cacheData); err != nil {
1182411827

1182511828
if strings.Contains(err.Error(), `cannot load field`) {
11826-
log.Printf("[ERROR] Error in workflow loading. Migrating org cache to new workflow handler (2): %s", err)
11829+
log.Printf("[ERROR] Error in workflow loading. Migrating org cache to new workflow handler (3): %s", err)
1182711830
err = nil
1182811831
} else {
1182911832
log.Printf("[WARNING] Error in cache key loading for %s: %s", id, err)
@@ -13127,7 +13130,7 @@ func GetSuggestion(ctx context.Context, id string) (*Suggestion, error) {
1312713130
key := datastore.NameKey(nameKey, strings.ToLower(id), nil)
1312813131
if err := project.Dbclient.Get(ctx, key, suggestion); err != nil {
1312913132
if strings.Contains(err.Error(), `cannot load field`) {
13130-
log.Printf("[ERROR] Error in workflow loading. Migrating suggestions to new workflow handler (1): %s", err)
13133+
log.Printf("[ERROR] Error in workflow loading. Migrating suggestions to new workflow handler (4): %s", err)
1313113134
err = nil
1313213135
} else {
1313313136
return suggestion, err

0 commit comments

Comments
 (0)