celery-singleton
celery-singleton copied to clipboard
steinitzu
Seamlessly prevent duplicate executions of celery tasks
Handle Retry
This close definitively pull request GH-8, GH-9 and issues GH-10, GH-20. I think that with some like this can be chain works also.
Problem: Singleton base are not supported if rabbitmq broker are used to assimilate the tasks. **Error: Redis URL must specify one of the following schemes (redis://, rediss://, unix://)** If there...
Accept redis with ssl when sigleton_backend_url is not informed
Adds `release_on_start` to the task configuration. Passing `release_on_start=True` to a singleton task makes the task release the lock when the job starts running, rather than when it has finished. Note:...
Fixes cases such as #42 #36 [`json.dumps()`](https://docs.python.org/3/library/json.html#json.dumps) accepts an optional `cls` of a [`jsonJSONEncoder`](https://docs.python.org/3/library/json.html#json.JSONEncoder) This matches the intention of the `json` library. This is great for cases where users use...
I'm running two EC2 instances connected to 1 Redis cache. Each EC2 instance is running a celery beat and 4 workers of celery 4.4.7 and celery-singleton 0.3.1. I'm trying to...
To aid, I would propose we add [logging](https://docs.python.org/3/library/logging.html) to the package 1. job name, args, kwargs + generating ID 2. checking for lock 3. creating lock 4. clearing lock By...
In re: #36 @steinitzu Are you open to accepting a PR [`json.JSONEncoder`](https://docs.python.org/3/library/json.html#json.JSONEncoder) in the settings? It can be passed to the [`json.dumps`](https://docs.python.org/3/library/json.html#json.dumps)'s `cls=` in [`celery_singleton.util::generate_lock()`](https://github.com/steinitzu/celery-singleton/blob/0.3.1/celery_singleton/util.py#L8-L9) This is a common practice...