Fix repo reference in ProcessExpirationsTask. (#661)

google · Apr 29, 2019 · c50a371 · c50a371
1 parent 6826513
commit c50a371
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/app/tasksmodule/deletion.py b/app/tasksmodule/deletion.py
@@ -98,9 +98,9 @@ def post(self, request, *args, **kwargs):
                     delete.delete_person(None, person, send_notices=False)
                 cursor = next_cursor
         except runtime.DeadlineExceededError:
-            self._schedule_task(repo, cursor)
+            self._schedule_task(self.env.repo, cursor)
         except datastore_errors.Timeout:
-            self._schedule_task(repo, cursor)
+            self._schedule_task(self.env.repo, cursor)
         return django.http.HttpResponse('')