diff --git a/kombu/transport/django/managers.py b/kombu/transport/django/managers.py index 8e816315..d41f5d91 100644 --- a/kombu/transport/django/managers.py +++ b/kombu/transport/django/managers.py @@ -53,6 +53,8 @@ class QueueManager(models.Manager): def select_for_update(qs): + if connection.vendor == 'oracle': + return qs try: return qs.select_for_update() except AttributeError: