Skip to content

Commit

Permalink
rename method
Browse files Browse the repository at this point in the history
Signed-off-by: nyagamunene <[email protected]>
  • Loading branch information
nyagamunene committed Jan 24, 2025
1 parent 68bc7a0 commit d771f2d
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions re/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -262,7 +262,7 @@ func (re *re) StartScheduler(ctx context.Context) error {
}

for _, rule := range page.Rules {
if rule.shouldRunRule(startTime) {
if rule.shouldRun(startTime) {
go func(r Rule) {
msg := &messaging.Message{
Channel: r.InputChannel,
Expand All @@ -276,7 +276,7 @@ func (re *re) StartScheduler(ctx context.Context) error {
}
}

func (r Rule) shouldRunRule(startTime time.Time) bool {
func (r Rule) shouldRun(startTime time.Time) bool {
// Don't run if the rule's start time is in the future
// This allows scheduling rules to start at a specific future time
if r.Schedule.StartDateTime.After(startTime) {
Expand Down

0 comments on commit d771f2d

Please sign in to comment.