I'm using celery-once to make sure some tasks are only run one at a time. The lock is acquired in apply_async and released in after_return.
When I use the CeleryIntegration I'm not seeing any of the locks being released after the task has finished running. I'm not very familiar with the inner workings of celery, but any ideas what's going on?