diff --git a/firestore/google/cloud/firestore_v1/watch.py b/firestore/google/cloud/firestore_v1/watch.py
index 4140a58ad8fe..8f93c56b5b6c 100644
--- a/firestore/google/cloud/firestore_v1/watch.py
+++ b/firestore/google/cloud/firestore_v1/watch.py
@@ -352,7 +352,7 @@ def for_query(
         cls, query, snapshot_callback, snapshot_class_instance, reference_class_instance
     ):
         query_target = firestore_pb2.Target.QueryTarget(
-            parent=query._client._database_string, structured_query=query._to_protobuf()
+            parent=query._parent._parent_info()[0], structured_query=query._to_protobuf()
         )
 
         return cls(