Compare commits

...

4 Commits

Author SHA1 Message Date
bel 18ac13fd57 should not execute feed if version.url=="" 2025-12-10 08:40:28 -07:00
bel 375fc1000a feeds for each runs all and returns all errs 2025-12-10 08:38:59 -07:00
bel 47c7aa74d3 uncap retries on main 2025-12-10 08:23:54 -07:00
bel a6aad2820d cap retries 2025-12-10 08:13:45 -07:00
3 changed files with 7 additions and 3 deletions

View File

@ -132,6 +132,5 @@ func runner(ctx context.Context, k string, foo func(context.Context) error) func
case <-time.After(time.Second):
}
}
return err
}
}

View File

@ -72,15 +72,20 @@ func ForEach(ctx context.Context, cb func(Feed) error) error {
return err
}
var errs []string
for _, id := range ids {
feed, err := Get(ctx, id.ID)
if err != nil {
return err
} else if err := cb(feed); err != nil {
return err
errs = append(errs, fmt.Sprintf(`failed to fetch %s: %v`, id.ID, err))
}
}
if len(errs) > 0 {
return fmt.Errorf("failed some callbacks: %+v", errs)
}
return nil
}

View File

@ -28,7 +28,7 @@ var (
)
func (feed Feed) ShouldExecute() (bool, error) {
if !feed.Entry.Deleted.IsZero() {
if !feed.Entry.Deleted.IsZero() || feed.Version.URL == "" {
return false, nil
}
next, err := feed.Next()