Debug CI...

workers/fetch_enqueue_worker.go

@@ -2,6 +2,7 @@ package workers
 
 import (
 	"context"
+	"fmt"
 	"time"
 
 	"github.com/interline-io/log"
@@ -57,6 +58,7 @@ func (w *FetchEnqueueWorker) Run(ctx context.Context, job jobs.Job) error {
 			}
 		}
 	}
+	fmt.Printf("checkUrlTypes %#v\n", checkUrlTypes)
 
 	// Check for fetch wait times and error backoffs
 	// This is structured to avoid bad N+1 queries
@@ -71,19 +73,25 @@ func (w *FetchEnqueueWorker) Run(ctx context.Context, job jobs.Job) error {
 				feedIds = append(feedIds, feed.ID)
 			}
 		}
+		fmt.Printf("feedIds %#v\n", feedIds)
+
 		feedChecks, err := actions.CheckFetchWaitBatch(ctx, db, feedIds, urlType)
 		if err != nil {
 			return err
 		}
 		var feedsOk []actions.CheckFetchWaitResult
 		for _, check := range feedChecks {
+			fmt.Printf("check %#v\n", check)
 			if check.OK() || w.IgnoreFetchWait {
+				fmt.Printf("ok\n")
 				feedsOk = append(feedsOk, check)
 			}
 		}
 		feedsByUrlType[urlType] = feedsOk
 	}
 
+	fmt.Printf("feedsByUrlType %#v\n", feedsByUrlType)
+
 	// Static fetch
 	var jj []jobs.Job
 	for _, urlType := range staticKeys {