tasks.py

# tasks.py
import logging
from celery import Celery
from db.db_utils import get_connection, store_result_to_db


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

app.conf.update(
    result_expires=3600,
    task_serializer='json',
    result_serializer='json',
    accept_content=['json'],
    timezone='UTC',
    enable_utc=True,
)

@app.task
def insert_result_async(run_key, mapping):
    logging.info(f"Inserting result for run_key: {run_key}, mapping: {mapping['input_word']}")
    db_conn = get_connection()
    db_cursor = db_conn.cursor()
    store_result_to_db(db_cursor, db_conn, run_key, mapping)
    db_conn.close()