Mapreduce to get/put Connection instances.
Underlying purpose is to add ignored_by_org field.
Change-Id: I8e36c736ca372ac555f84b3c543eb1c3f16d55e8
diff --git a/app/mapreduce.yaml b/app/mapreduce.yaml
index 7122368..37fcf92 100644
--- a/app/mapreduce.yaml
+++ b/app/mapreduce.yaml
@@ -377,3 +377,11 @@
value: soc.modules.gci.models.score.GCIOrgScore
- name: dry_run
value: True
+
+- name: ConnectionGetPut
+ mapper:
+ input_reader: mapreduce.input_readers.DatastoreKeyInputReader
+ handler: melange.mapreduce.connections_getput.process
+ params:
+ - name: entity_kind
+ value: melange.models.connection.Connection
diff --git a/app/melange/mapreduce/connections_getput.py b/app/melange/mapreduce/connections_getput.py
new file mode 100644
index 0000000..26ec519
--- /dev/null
+++ b/app/melange/mapreduce/connections_getput.py
@@ -0,0 +1,35 @@
+# Copyright 2015 the Melange authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+"""MapReduce to get and put all Connection instances.
+
+Used after a new property is added. Originally written after we added
+the ignored_by_org property.
+"""
+
+from melange.appengine import django_setup
+django_setup.setup_environment()
+
+from google.appengine.ext import ndb
+
+from mapreduce import operation
+
+import melange.models.connection # pylint: disable=unused-import
+
+
+def process(connection_key):
+ connection_key = ndb.Key.from_old_key(connection_key)
+ connection = connection_key.get()
+ connection.put()
+ yield operation.counters.Increment('instances getput')
