thepaperpilot/forgejo
1
0
Fork 0
Code Issues Pull requests Releases Activity Actions

Always delete existing scheduled action tasks (#27662)

Browse source 
Fixes #27650
This commit is contained in:
KN4CK3R 2023-10-18 12:34:39 +02:00 committed by GitHub
parent 4e98224a45
commit 83186eca80
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
services/actions/notifier_helper.go
View file

@ -374,11 +374,6 @@ func handleSchedules(
commit *git.Commit, commit *git.Commit,
input *notifyInput, input *notifyInput,
) error { ) error {
if len(detectedWorkflows) == 0 {
log.Trace("repo %s with commit %s couldn't find schedules", input.Repo.RepoPath(), commit.ID)
return nil
}
branch, err := commit.GetBranchName() branch, err := commit.GetBranchName()
if err != nil { if err != nil {
return err return err
@ -388,18 +383,20 @@ func handleSchedules(
return nil return nil
} }
rows, _, err := actions_model.FindSchedules(ctx, actions_model.FindScheduleOptions{RepoID: input.Repo.ID}) if count, err := actions_model.CountSchedules(ctx, actions_model.FindScheduleOptions{RepoID: input.Repo.ID}); err != nil {
if err != nil { log.Error("CountSchedules: %v", err)
log.Error("FindCrons: %v", err)
return err return err
} } else if count > 0 {
if len(rows) > 0 {
if err := actions_model.DeleteScheduleTaskByRepo(ctx, input.Repo.ID); err != nil { if err := actions_model.DeleteScheduleTaskByRepo(ctx, input.Repo.ID); err != nil {
log.Error("DeleteCronTaskByRepo: %v", err) log.Error("DeleteCronTaskByRepo: %v", err)
} }
} }
if len(detectedWorkflows) == 0 {
log.Trace("repo %s with commit %s couldn't find schedules", input.Repo.RepoPath(), commit.ID)
return nil
}
p, err := json.Marshal(input.Payload) p, err := json.Marshal(input.Payload)
if err != nil { if err != nil {
return fmt.Errorf("json.Marshal: %w", err) return fmt.Errorf("json.Marshal: %w", err)