|
66 | 66 | else:
|
67 | 67 | NUM_ITERATIONS = 10
|
68 | 68 | MIN_ITERATION_TIME = 30
|
69 |
| - MAX_ITERATION_TIME = 60 |
| 69 | + MAX_ITERATION_TIME = 120 |
70 | 70 | NUM_DOCS = 10000
|
71 | 71 |
|
72 | 72 | TEST_PATH = os.environ.get("TEST_PATH", Path(os.path.realpath(__file__)).parent.parent / "odm-data")
|
@@ -205,14 +205,16 @@ def setUp(self):
|
205 | 205 | model = SmallFlatModel(**doc)
|
206 | 206 | model.save()
|
207 | 207 | self.models = list(SmallFlatModel.objects.all())
|
208 |
| - self.data_size = len(encode({"field1": "updated_value"})) * NUM_DOCS |
| 208 | + self.data_size = len(encode({"field1": "updated_value0"})) * NUM_DOCS |
| 209 | + self.iteration = 0 |
209 | 210 |
|
210 | 211 | def do_task(self):
|
211 | 212 | for model in self.models:
|
212 |
| - model.field1 = "updated_value" |
| 213 | + model.field1 = "updated_value" + str(self.iteration) |
213 | 214 | model.save()
|
| 215 | + self.iteration += 1 |
214 | 216 |
|
215 |
| - def after(self): |
| 217 | + def tearDown(self): |
216 | 218 | SmallFlatModel.objects.all().delete()
|
217 | 219 |
|
218 | 220 |
|
@@ -285,14 +287,16 @@ def setUp(self):
|
285 | 287 | model = LargeFlatModel(**doc)
|
286 | 288 | model.save()
|
287 | 289 | self.models = list(LargeFlatModel.objects.all())
|
288 |
| - self.data_size = len(encode({"field1": "updated_value"})) * NUM_DOCS |
| 290 | + self.data_size = len(encode({"field1": "updated_value0"})) * NUM_DOCS |
| 291 | + self.iteration = 0 |
289 | 292 |
|
290 | 293 | def do_task(self):
|
291 | 294 | for model in self.models:
|
292 |
| - model.field1 = "updated_value" |
| 295 | + model.field1 = "updated_value" + str(self.iteration) |
293 | 296 | model.save()
|
| 297 | + self.iteration += 1 |
294 | 298 |
|
295 |
| - def after(self): |
| 299 | + def tearDown(self): |
296 | 300 | LargeFlatModel.objects.all().delete()
|
297 | 301 |
|
298 | 302 |
|
@@ -342,14 +346,16 @@ def setUp(self):
|
342 | 346 | super().setUp()
|
343 | 347 | self.create_model()
|
344 | 348 | self.models = list(LargeNestedModel.objects.all())
|
345 |
| - self.data_size = len(encode({"field1": "updated_value"})) * NUM_DOCS |
| 349 | + self.data_size = len(encode({"field1": "updated_value0"})) * NUM_DOCS |
| 350 | + self.iteration = 0 |
346 | 351 |
|
347 | 352 | def do_task(self):
|
348 | 353 | for model in self.models:
|
349 |
| - model.embedded_str_doc_1.field1 = "updated_value" |
| 354 | + model.embedded_str_doc_1.field1 = "updated_value" + str(self.iteration) |
350 | 355 | model.save()
|
| 356 | + self.iteration += 1 |
351 | 357 |
|
352 |
| - def after(self): |
| 358 | + def tearDown(self): |
353 | 359 | LargeNestedModel.objects.all().delete()
|
354 | 360 |
|
355 | 361 |
|
|
0 commit comments