diff --git a/heat_integrationtests/functional/test_event_sinks.py b/heat_integrationtests/functional/test_event_sinks.py
index a7e75795af..61f1bfabb3 100644
--- a/heat_integrationtests/functional/test_event_sinks.py
+++ b/heat_integrationtests/functional/test_event_sinks.py
@@ -12,7 +12,7 @@
 
 import uuid
 
-from zaqarclient.queues.v1 import client as zaqarclient
+from zaqarclient.queues.v2 import client as zaqarclient
 
 from heat_integrationtests.common import test
 from heat_integrationtests.functional import functional_base
@@ -53,7 +53,7 @@ resources:
             }
         }
 
-        zaqar = zaqarclient.Client(conf=conf, version=1.1)
+        zaqar = zaqarclient.Client(conf=conf)
         queue = zaqar.queue(queue_id)
 
         def validate_messages():
diff --git a/heat_integrationtests/functional/test_waitcondition.py b/heat_integrationtests/functional/test_waitcondition.py
index fd5399fadc..f79d49bed6 100644
--- a/heat_integrationtests/functional/test_waitcondition.py
+++ b/heat_integrationtests/functional/test_waitcondition.py
@@ -13,7 +13,7 @@
 import json
 
 from keystoneclient.v3 import client as keystoneclient
-from zaqarclient.queues.v1 import client as zaqarclient
+from zaqarclient.queues.v2 import client as zaqarclient
 
 from heat_integrationtests.functional import functional_base
 
@@ -63,7 +63,7 @@ outputs:
             }
         }
 
-        zaqar = zaqarclient.Client(endpoint, conf=conf, version=1.1)
+        zaqar = zaqarclient.Client(endpoint, conf=conf)
 
         queue = zaqar.queue(signal['queue_id'])
         queue.post({'body': {'data': 'here!', 'id': 'data_id'}, 'ttl': 600})