diff --git a/meshmode/discretization/connection/direct.py b/meshmode/discretization/connection/direct.py
index 8ba6d0979efa22c5e73acd4c7aa088f63e02727d..20f5cdb94023b15e42d713dffd538986d3bc823c 100644
--- a/meshmode/discretization/connection/direct.py
+++ b/meshmode/discretization/connection/direct.py
@@ -372,7 +372,7 @@ class DirectDiscretizationConnection(DiscretizationConnection):
             raise TypeError("non-array passed to discretization connection")
 
         if self.is_surjective:
-            result = self.to_discr.empty(dtype=vec.dtype)
+            result = self.to_discr.empty(queue, dtype=vec.dtype)
         else:
             result = self.to_discr.zeros(queue, dtype=vec.dtype)