@worker_ready.connect<EOL>def on_worker_ready(**_):
WORKER_READY.append(True)<EOL>
Called when the Celery worker thread is ready to do work.

    This is to avoid race conditions since everything is in one python process.