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):
|
case <-time.After(time.Second):
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return err
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -72,15 +72,20 @@ func ForEach(ctx context.Context, cb func(Feed) error) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var errs []string
|
||||||
for _, id := range ids {
|
for _, id := range ids {
|
||||||
feed, err := Get(ctx, id.ID)
|
feed, err := Get(ctx, id.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
} else if err := cb(feed); err != nil {
|
} 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
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -28,7 +28,7 @@ var (
|
||||||
)
|
)
|
||||||
|
|
||||||
func (feed Feed) ShouldExecute() (bool, error) {
|
func (feed Feed) ShouldExecute() (bool, error) {
|
||||||
if !feed.Entry.Deleted.IsZero() {
|
if !feed.Entry.Deleted.IsZero() || feed.Version.URL == "" {
|
||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
next, err := feed.Next()
|
next, err := feed.Next()
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue