from celery import Celery
from decouple import config # Import the config function from python-decouple


from app.core.config import get_config

settings = get_config()


# Create a Celery instance
celery_app = Celery(
    'celery_tasks', 
    broker = settings.CELERY_BROKER_URL,
    backend = settings.CELERY_RESULT_BACKEND,
    include=[
        # 'app.tasks.extract_subtitles',
        'app.tasks.face_tasks',
    ]
)
  
# Set broker_connection_retry_on_startup to True
celery_app.conf.broker_connection_retry_on_startup = True

# celery_app.conf.task_acks_late = True

# Define a Celery task
@celery_app.task
def example_task(param):
    """
    Example Celery task.
    """
    # Your task logic here
    result = param + 10
    return result