Celery vs Temporal

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 { Worker, NativeConnection } from '@temporalio/worker';
import { workflowFn } from './workflows';

const worker = await Worker.create({
  connection: await NativeConnection.connect({ address: 'localhost:7233' }),
  namespace: 'default',
  taskQueue: 'my-queue',
  workflowsPath: require.resolve('./workflows'),
  activities: { greet: async (name) => `Hello, ${name}!` },
});

await worker.run();