Skip to content

Commit

Permalink
Schedule global jobs atomically
Browse files Browse the repository at this point in the history
  • Loading branch information
akadusei committed Jul 22, 2024
1 parent 54f3f03 commit 53fce2a
Showing 1 changed file with 25 additions and 9 deletions.
34 changes: 25 additions & 9 deletions src/worker.cr
Original file line number Diff line number Diff line change
Expand Up @@ -6,15 +6,31 @@ Habitat.raise_if_missing_settings!

exit if LuckyEnv.development?

DeleteBearerLoginsJob.run_every(1.week, id: "delete-bearer-logins-weekly")

DeleteEmailConfirmationsJob.run_every(
1.week,
id: "delete-email-confirmations-weekly"
)

DeleteLoginsJob.run_every(1.week, id: "delete-logins-weekly")
DeletePasswordResetsJob.run_every(1.week, id: "delete-password-resets-weekly")
Mel.redis.multi do |redis|
DeleteBearerLoginsJob.run_every(
1.week,
redis: redis,
id: "delete-bearer-logins-weekly"
)

DeleteEmailConfirmationsJob.run_every(
1.week,
redis: redis,
id: "delete-email-confirmations-weekly"
)

DeleteLoginsJob.run_every(
1.week,
redis: redis,
id: "delete-logins-weekly"
)

DeletePasswordResetsJob.run_every(
1.week,
redis: redis,
id: "delete-password-resets-weekly"
)
end

ARGV.first?.try { |worker_id| Mel.settings.worker_id = worker_id.to_i }

Expand Down

0 comments on commit 53fce2a

Please sign in to comment.