Compare commits
4 Commits
b26afcb325
...
18ac13fd57
| Author | SHA1 | Date |
|---|---|---|
|
|
18ac13fd57 | |
|
|
375fc1000a | |
|
|
47c7aa74d3 | |
|
|
a6aad2820d |
|
|
@ -132,6 +132,5 @@ func runner(ctx context.Context, k string, foo func(context.Context) error) func
|
|||
case <-time.After(time.Second):
|
||||
}
|
||||
}
|
||||
return err
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -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()
|
||||
|
|
|
|||
Loading…
Reference in New Issue