celery shared_task ignoring flow-control statements?

This is a project which was already set up, and which I joined the team to help maintain, so I can’t speak to the choice of version numbers. I’m quite sure our libraries are way out of date, so I’m just trying to figure out the best way to work around (it seems) not having a working continue statement.

python 3.11.6,

django 4.2.13,

from the requirements file, it just lists django-celery-beat and celery.

The whole thing is being run as a Docker image.

In the (dunder)init for our app directory is this:

from .celery import app as celery_app

_all_ = [‘celery_app’]

and then (trying to hide any company info) that .celery file is:

import os

from celery import Celery

os.environ.setdefault(“DJANGO_SETTINGS_MODULE”, “abc_dashboard.settings”)

app = Celery(“abc_dashboard”)

app.config_from_object(“django.conf:settings”, namespace=“CELERY”)

app.autodiscover_tasks()

Then, in that module which runs the process_logs function, we import shared_task from celery.