Celery vs Inngest

from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379/0')

@app.task
def send_welcome_email(user_id: int):
    user = User.objects.get(id=user_id)
    email_service.send_welcome(user.email)

@app.task
def process_upload(file_path: str):
    result = run_etl_pipeline(file_path)
    return result

# Trigger from your view:
send_welcome_email.delay(user.id)

# Run worker:
# celery -A tasks worker --loglevel=info

import { Inngest } from 'inngest';

const inngest = new Inngest({ id: 'my-app' });

// Define a background function
export const sendWelcomeEmail = inngest.createFunction(
  { id: 'send-welcome-email' },
  { event: 'user/signup' },
  async ({ event, step }) => {
    // Step 1: send email
    await step.run('send-email', () =>
      sendEmail(event.data.email, 'Welcome!')
    );

    // Step 2: wait 3 days, then send follow-up
    await step.sleep('wait-3-days', '3 days');
    await step.run('send-followup', () =>
      sendEmail(event.data.email, 'How are you finding things?')
    );
  }
);