Wait until migrations are generated. Sometimes it takes a little bit of time for stats to get updated. We generate migrations until we get at least one migration
(self)
| 197 | return res |
| 198 | |
| 199 | def get_migrations(self): |
| 200 | """ Wait until migrations are generated. Sometimes it takes a little bit of time for stats to get updated. We generate migrations |
| 201 | until we get at least one migration """ |
| 202 | def generate_migrations(): |
| 203 | drs_plan = self.cluster.generateDrsPlan(self.apiclient, migrations=4) |
| 204 | if len(drs_plan["migrations"]) > 0: |
| 205 | return True, drs_plan["migrations"] |
| 206 | return False, drs_plan["migrations"] |
| 207 | |
| 208 | res, migrations = wait_until(10, 30, generate_migrations) |
| 209 | if not res: |
| 210 | raise Exception("Failed to generate drs migrations") |
| 211 | return migrations |
| 212 | |
| 213 | @attr(tags=["advanced"], required_hardware="false") |
| 214 | def test_01_condensed_drs_algorithm(self): |
no test coverage detected