Vfrdtyky

I have been using Celery previously in this project, I have tasks.py file in my app directory where some tasks are defined and scheduled in the Celery.py file but when i run celery -A project worker -l info the tasks in app/tasks.py file are not getting discovered due to a reason not able to figure out.
Here is my tasks.py file

@shared_task

def fetch_interface_logs(*products):

"""

Function responsible for fetching the interface logs

"""

# print(products)

for product in products:

    print(product[0])

    headers = {'X-Auth-Token': ACCESS_TOKEN, "Content-Type": 'application/json'}

    log_URL = BASE_URL_PROD + ACTION_URLS.get('logs').format(product[0])

    interface_resp = requests.get(log_URL, headers=headers).json()



    if Cloud.objects.filter(product_uid=product[0]):

        base_obj = Cloud.objects.get(product_uid=product[0])



    elif Cloudx.objects.filter(product_uid=product[0]):

        base_obj = Cloudx.objects.get(product_uid=product[0])

    interface_json = interface_resp['data']



    for log in interface_json:

        if log['event']:

            interface = InterfaceLogs()

            interface.event_name = log['event']

            interface.message = log['message']

            interface.resource_type = log['resource_type']

            interface.log_time = arrow.get(int(log['time']) / 1000).datetime



            interface.save()

            # print(interface.log_time)



            base_obj.interface_logs.add(interface)

            base_obj.save()

return

and here is the code for the Celery.py file

from __future__ import absolute_import

import os

from celery import Celery

from celery import shared_task

from django.conf import settings

from celery.schedules import crontab

import django



os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'cloud_sdn.settings')

django.setup()

app = Celery('cloud_sdn')



# Using a string here means the worker doesn't have to serialize

# the configuration object to child processes.

# - namespace='CELERY' means all celery-related configuration keys

#   should have a `CELERY_` prefix.

app.config_from_object(settings, namespace='CELERY')



# Load all the tasks automatically

app.autodiscover_tasks()



from app.models import Cloudx, Cloud





app.conf.beat_schedule = {



    'add-cloudx_interface-logs-everyday-afternoon': {

        'task': 'fetch_interface_logs',

        'schedule': crontab(hour=17, minute=2),

        'args': list(Cloudx.objects.all().values_list('product_uid')),



    },

    'add-cloud_interface-logs-everyday-afternoon': {

        'task': 'fetch_interface_logs',

        'schedule': crontab(hour=17, minute=12),

        'args': list(Cloud.objects.all().values_list('product_uid')),



    }

and here is the code for the init.py file

from __future__ import absolute_import, unicode_literals



# This will make sure the app is always imported when

# Django starts so that shared_task will use this app.

from .celery import app as celery_app



__all__ = ['celery_app']

I am using redis as the broker.

Are you starting the worker process with the correct directory? Your directory is cloud_sdn

celery -A <directory> worker -l info