diff options
| author | Mikhail Shchatko <mikhail.shchatko@mongodb.com> | 2021-06-01 15:21:26 +0300 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-06-02 08:12:54 +0000 |
| commit | cf55779be0b1ed2f12c71e13e634b81007094777 (patch) | |
| tree | 2f9e22fb956ca44e2ff10237b2579f66f6d398c7 | |
| parent | d8ba27a3e0981a7014846dcc7634aa588329bf0b (diff) | |
| download | mongo-cf55779be0b1ed2f12c71e13e634b81007094777.tar.gz | |
SERVER-57112 Fix CheckTenantMigrationDBHash duplicated logs
| -rw-r--r-- | buildscripts/resmokelib/testing/hooks/tenant_migration.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/buildscripts/resmokelib/testing/hooks/tenant_migration.py b/buildscripts/resmokelib/testing/hooks/tenant_migration.py index 9fb0cd32ede..b9e86510c60 100644 --- a/buildscripts/resmokelib/testing/hooks/tenant_migration.py +++ b/buildscripts/resmokelib/testing/hooks/tenant_migration.py @@ -60,7 +60,7 @@ class ContinuousTenantMigration(interface.Hook): # pylint: disable=too-many-ins def before_test(self, test, test_report): """Before test.""" self.logger.info("Resuming the tenant migration thread.") - self._tenant_migration_thread.resume() + self._tenant_migration_thread.resume(test.logger) def after_test(self, test, test_report): """After test.""" @@ -316,7 +316,7 @@ class _TenantMigrationThread(threading.Thread): # pylint: disable=too-many-inst self.__lifecycle.stop() self._is_stopped_evt.set() # Unpause to allow the thread to finish. - self.resume() + self.resume(self.logger) self.join() def pause(self): @@ -335,8 +335,9 @@ class _TenantMigrationThread(threading.Thread): # pylint: disable=too-many-inst " ContinuousTenantMigration, but wasn't".format( self._tenant_migration_fixture.pids())) - def resume(self): + def resume(self, logger): """Resume the thread before test.""" + self.logger = logger self.__lifecycle.mark_test_started() def _wait(self, timeout): |