Fix Task.enqueue() to use an exact queue name match

This commit is contained in:
allegroai 2020-05-22 10:17:17 +03:00
parent 5c4cfa9643
commit 3491646ea9

View File

@ -725,7 +725,7 @@ class Task(_Task):
task_id = task if isinstance(task, six.string_types) else task.id
session = cls._get_default_session()
if not queue_id:
req = queues.GetAllRequest(name=queue_name, only_fields=["id"])
req = queues.GetAllRequest(name=exact_match_regex(queue_name), only_fields=["id"])
res = cls._send(session=session, req=req)
if not res.response.queues:
raise ValueError('Could not find queue named "{}"'.format(queue_name))