Open
Description
we already have an identifier for a job.
Line 754 in 63f3701
why do we need another one in the locker ? Why don't we just pass that as a parameter ?
Line 387 in 63f3701
func (g *GormLocker) Lock(ctx context.Context, key string) (gocron.Lock, error) {
ji := g.jobIdentifier(ctx, key) // <- here
cjb := &CronJobLock{
JobName: key,
JobIdentifier: ji,
Worker: g.worker,
Status: StatusRunning,
}
tx := g.db.WithContext(ctx).Create(cjb)
if tx.Error != nil {
return nil, tx.Error
}
return &gormLock{db: g.db, id: cjb.GetID()}, nil
}
Metadata
Metadata
Assignees
Labels
No labels