code: def reset_lock(self):
          
          redis_key = self.CELERY_LOCK.format(task_id=self.task_identifier)
          self.celery_self.backend.client.delete(redis_key)
docs: Removed the lock regardless of timeout.