from celery import Celery

app = Celery('requests',
             broker='redis://localhost:6379/0',
             backend='redis://localhost:6379/0',
             include=['celery_tasks.tasks.softsub_handler','celery_tasks.tasks.title_request_handler','celery_tasks.tasks.hardsub_handler',
                      'celery_tasks.tasks.quality_handler','celery_tasks.tasks.subtitle_sync_engine','celery_tasks.tasks.uploader',
                      'celery_tasks.tasks.url_downloader','celery_tasks.tasks.task_router','celery_tasks.tasks.dubbed_handler',
                      'celery_tasks.tasks.find_title_from_sources','celery_tasks.tasks.new_title_updater','celery_tasks.tasks.batch_sender']
             )
app.conf.task_routes = {
    'celery_tasks.tasks.hardsub_handler': {'queue': 'hardsubs'},
    'celery_tasks.tasks.softsub_handler': {'queue': 'softsubs'},
    'celery_tasks.tasks.title_request_handler': {'queue': 'title_requests'},
    'celery_tasks.tasks.quality_handler': {'queue': 'qualities'},
    'celery_tasks.tasks.subtitle_sync_engine': {'queue': 'sync_subtitles'},
    'celery_tasks.tasks.video_uploader': {'queue': 'uploads'},
    'celery_tasks.tasks.url_downloader': {'queue': 'downloads'},
    'celery_tasks.tasks.task_router': {'queue': 'router'},
    'celery_tasks.tasks.dubbed_handler': {'queue': 'dubbeds'},
    'celery_tasks.tasks.find_title_from_sources': {'queue': 'find_titles'},
    'celery_tasks.tasks.new_title_updater': {'queue': 'updates'},
    'celery_tasks.tasks.batch_sender': {'queue': 'batches'},
}

if __name__ == '__main__':
    app.start()