cleanup_expired_sessions:
cron: '0 2 * * *' # Daily at 2 AM
class: CleanupExpiredSessionsWorker
queue: low
description: Remove expired sessions from Redis
send_daily_digest:
cron: '0 9 * * *' # Daily at 9 AM
class: SendDailyDigestWorker
queue: default
description: Send daily digest emails to active users
refresh_trending_cache:
cron: '*/15 * * * *' # Every 15 minutes
class: RefreshTrendingCacheWorker
queue: default
description: Update trending posts cache
class CleanupExpiredSessionsWorker
include Sidekiq::Worker
sidekiq_options queue: :low, retry: 3
def perform
cutoff_time = 30.days.ago
expired_count = Session.where('updated_at < ?', cutoff_time).delete_all
Rails.logger.info("Cleaned up #{expired_count} expired sessions")
end
end
Recurring tasks like cleanup jobs, report generation, or cache warming need reliable scheduling. The sidekiq-scheduler gem extends Sidekiq with cron-like scheduling without requiring separate infrastructure like cron or Kubernetes CronJobs. I define scheduled jobs in config/sidekiq_scheduler.yml with standard cron syntax and optional parameters. Jobs run on only one Sidekiq instance even in multi-process deployments thanks to Redis-based locking. I use scheduled jobs for daily aggregations, weekly email digests, or hourly cleanup of expired records. The key is keeping scheduled jobs idempotent since timing isn't guaranteed to be exact. For critical time-sensitive jobs, I add monitoring to alert when a scheduled job hasn't run recently.
Related snips
class CommentsController < ApplicationController
before_action :set_post
def create
@comment = @post.comments.build(comment_params)
System test: asserting Turbo Stream responses
class Post < ApplicationRecord
belongs_to :author, class_name: 'User'
has_many :comments, dependent: :destroy
scope :published, -> { where.not(published_at: nil).where('published_at <= ?', Time.current) }
scope :draft, -> { where(published_at: nil) }
ActiveRecord scopes for reusable query logic
module Api
module V1
class UsersController < BaseController
def show
user = User.includes(:profile).find(params[:id])
ETags for conditional requests and caching
class PostsController < ApplicationController
def index
@posts = Post.includes(:author)
.order(created_at: :desc)
.page(params[:page])
.per(10)
Turbo Frames: infinite scroll with lazy-loading frame
require "csv"
class PeopleCsvStream
include Enumerable
HEADERS = %w[id full_name email signed_up_at plan].freeze
Resilient CSV Export as a Streamed Response
<form data-controller="query-sync" data-action="change->query-sync#apply">
<select name="status" class="rounded border p-2">
<option value="">Any</option>
<option value="open">Open</option>
<option value="closed">Closed</option>
</select>
Filter UI that syncs query params via Stimulus (no front-end router)
Share this code
Here's the card — post it anywhere.