|
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