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
|
ORDER BY executed_at DESC
|
||||||
LIMIT 1
|
LIMIT 1
|
||||||
`)
|
`)
|
||||||
return result.Did, err
|
return result.Did.Add(time.Hour), err
|
||||||
}
|
}
|
||||||
|
|
||||||
func Record(ctx context.Context) error {
|
func Record(ctx context.Context) error {
|
||||||
|
|||||||
@@ -26,13 +26,20 @@ func One(ctx context.Context) error {
|
|||||||
defer can()
|
defer can()
|
||||||
|
|
||||||
lastD := ""
|
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 {
|
if d := path.Dir(p); d != lastD {
|
||||||
log.Printf("asses.One(%s/...)...", d)
|
log.Printf("asses.One(%s/...)...", d)
|
||||||
lastD = 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 {
|
func OneWith(ctx context.Context, rootds []string, cb CB) error {
|
||||||
|
|||||||
Reference in New Issue
Block a user