Hi all,
I'm using mapreduce library with pipelines and filters and NDB models. Everthing works very well !
My question:
Is it possible define filters in mapreduce.yaml file ? Like this:
mapreduce:
- name: Re-index
mapper:
input_reader: mapreduce.input_readers.DatastoreInputReader
handler: mr.review_entities
params:
- name: entity_kind
default: model.Entities
- name: shard_count
default: 20
- name: queue_name
default: fastest
- name: filters
default: [("status", "=", "ACTIVE")]