Implementing Pyvorin for Celery Workers

Task Compilation

Compile the body of Celery tasks for faster queue processing.

@app.task
@pyvorin.compile
def process_batch(batch_id):
    records = fetch_records(batch_id)
    return transform(records)

Throughput

Higher task throughput per worker means fewer workers and lower memory.

Chord and Group

Compile callback functions for chord unlock and group results.