@@ -404,7 +404,7 @@ def key_filter(client):
404
404
# [START key_filter]
405
405
query = client .query (kind = 'Task' )
406
406
first_key = client .key ('Task' , 'first_task' )
407
- query .add_filter ( '__key__' , '>' , first_key )
407
+ query .key_filter ( first_key , '>' )
408
408
# [END key_filter]
409
409
410
410
return list (query .fetch ())
@@ -477,7 +477,7 @@ def distinct_query(client):
477
477
478
478
# [START distinct_query]
479
479
query = client .query (kind = 'Task' )
480
- query .group_by = ['type' , 'priority' ]
480
+ query .distinct_on = ['type' , 'priority' ]
481
481
query .order = ['type' , 'priority' ]
482
482
query .projection = ['type' , 'priority' ]
483
483
# [END distinct_query]
@@ -491,7 +491,7 @@ def distinct_on_query(client):
491
491
492
492
# [START distinct_on_query]
493
493
query = client .query (kind = 'Task' )
494
- query .group_by = ['type' ]
494
+ query .distinct_on = ['type' ]
495
495
query .order = ['type' , 'priority' ]
496
496
# [END distinct_on_query]
497
497
@@ -506,7 +506,7 @@ def kindless_query(client):
506
506
507
507
# [START kindless_query]
508
508
query = client .query ()
509
- query .add_filter ( '__key__' , '>' , last_seen_key )
509
+ query .key_filter ( last_seen_key , '>' )
510
510
# [END kindless_query]
511
511
512
512
return list (query .fetch ())
@@ -722,10 +722,8 @@ def namespace_run_query(client):
722
722
start_namespace = client .key ('__namespace__' , 'g' )
723
723
end_namespace = client .key ('__namespace__' , 'h' )
724
724
query = client .query (kind = '__namespace__' )
725
- query .add_filter (
726
- '__key__' , '>=' , start_namespace )
727
- query .add_filter (
728
- '__key__' , '<' , end_namespace )
725
+ query .key_filter (start_namespace , '>=' )
726
+ query .key_filter (end_namespace , '<' )
729
727
730
728
filtered_namespaces = [entity .key .id_or_name for entity in query .fetch ()]
731
729
# [END namespace_run_query]
0 commit comments