mirror of
https://github.com/crawlab-team/crawlab.git
synced 2026-01-26 17:49:15 +01:00
code cleanup
This commit is contained in:
@@ -852,14 +852,6 @@ func SendNotifications(u model.User, t model.Task, s model.Spider) {
|
||||
}
|
||||
}
|
||||
|
||||
func UnlockLongTask(s model.Spider, n model.Node) {
|
||||
if s.IsLongTask {
|
||||
colName := "long-tasks"
|
||||
key := fmt.Sprintf("%s:%s", s.Id.Hex(), n.Id.Hex())
|
||||
_ = database.RedisClient.HDel(colName, key)
|
||||
}
|
||||
}
|
||||
|
||||
func InitTaskExecutor() error {
|
||||
c := cron.New(cron.WithSeconds())
|
||||
Exec = &Executor{
|
||||
|
||||
Reference in New Issue
Block a user