Okay problem solved, for future docs for others here was the problem:
When I started the celery workers, I was referencing the ‘app_global’ file like so:
celery -A app_global:celery_app worker --loglevel=DEBUG --concurrency=2
What I should have done was import the celery_app from app_global into app.py and run the worker like this:
celery -A app:celery_app worker --loglevel=DEBUG --concurrency=2
This solved my problem immediately.
Thank you @jinnyzor and @cdolfi for the help along the way, I improved my code because of your input.