In your cron_mapreduce.py add these two lines shard_count=int(self.request.get("shard_count", mr_control._DEFAULT_SHARD_COUNT))
mr_control.start_map( self.request.get("name"), self.request.get("reader_spec", "your_mapreduce.map"), self.request.get("reader_parameters", "mapreduce.input_readers.DatastoreInputReader"), { "entity_kind": self.request.get("entity_kind", "models.YourModel"), "processing_rate": int(self.request.get("processing_rate", 100)) }, shard_count = shard_count, mapreduce_parameters={"done_callback": self.request.get("done_callback", None) } ) 2011/2/10 Andrin von Rechenberg <andri...@gmail.com>: > Hey there > Today I created a library to run MapReduces as cron jobs in python. > See > here: http://devblog.miumeet.com/2011/02/schedule-mapreduce-daily-on-appengine.html > However, I didn't figure out how to I'm able to set the > shard_count programmatically. > In mapreduce/control.py there is a function I call: > > def start_map(name, > > handler_spec, > > reader_spec, > > reader_parameters, > > shard_count=_DEFAULT_SHARD_COUNT, > > [...]) > > However, no matter what o I pass as the shard_count argument, it is ignored. > > Any ideas? > > Cheers, > > -Andrin -- You received this message because you are subscribed to the Google Groups "Google App Engine" group. To post to this group, send email to google-appengine@googlegroups.com. To unsubscribe from this group, send email to google-appengine+unsubscr...@googlegroups.com. For more options, visit this group at http://groups.google.com/group/google-appengine?hl=en.