Compare commits
2 Commits
cb44644475
...
99c1061a18
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
99c1061a18 | ||
|
|
67840f6b28 |
@@ -26,7 +26,7 @@ func Next(ctx context.Context) (time.Time, error) {
|
||||
ORDER BY executed_at DESC
|
||||
LIMIT 1
|
||||
`)
|
||||
return result.Did, err
|
||||
return result.Did.Add(time.Hour), err
|
||||
}
|
||||
|
||||
func Record(ctx context.Context) error {
|
||||
|
||||
@@ -26,13 +26,20 @@ func One(ctx context.Context) error {
|
||||
defer can()
|
||||
|
||||
lastD := ""
|
||||
return OneWith(ctx, rootDs, func(ctx context.Context, p string) error {
|
||||
if err := OneWith(ctx, rootDs, func(ctx context.Context, p string) error {
|
||||
if d := path.Dir(p); d != lastD {
|
||||
log.Printf("asses.One(%s/...)...", d)
|
||||
lastD = d
|
||||
}
|
||||
return asses.One(ctx, p)
|
||||
})
|
||||
if err := asses.One(ctx, p); err != nil {
|
||||
log.Printf("asses.One(.../%s/%s)...: err: %v", path.Base(path.Dir(p)), path.Base(p), err)
|
||||
}
|
||||
return nil
|
||||
}); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return asses.Record(ctx)
|
||||
}
|
||||
|
||||
func OneWith(ctx context.Context, rootds []string, cb CB) error {
|
||||
|
||||
Reference in New Issue
Block a user