:concurrency: 10
:queues:
- [critical, 4]
- [default, 2]
- [low, 1]
class SendWelcomeEmailWorker
include Sidekiq::Worker
sidekiq_options queue: :default, retry: 5
def perform(user_id)
user = User.find_by(id: user_id)
return unless user
UserMailer.welcome_email(user).deliver_now
user.update_column(:welcome_email_sent_at, Time.current)
end
end
Moving slow operations to background jobs keeps API response times fast and improves perceived performance. Sidekiq with Redis provides a robust, production-proven job queue that handles millions of jobs per day. I organize workers into separate queues by priority (critical, default, low) and configure concurrency per queue to prevent low-priority bulk operations from starving urgent tasks. Each worker includes retry logic with exponential backoff, and I use sidekiq-unique-jobs to prevent duplicate processing when job parameters are identical. The key discipline is making workers idempotent—if a job runs twice due to at-least-once delivery semantics, it should produce the same result. I also instrument job execution time to identify slow workers that need optimization.
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].freezeResilient 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.
