Skip to content

tests: only flush() the kafka journal writer once per test

David Douard requested to merge generated-differential-D8740-source into generated-differential-D8740-target

instead of flushing it n times per test. Since the call to kafka Producer.flush() takes about 1s, reducing the number of calls to this method significantly reduce the execution time of the tests.

This required a small refactoring of the JournalBackfiller class to make the journal writer live out of the scope of the run() so the test can access the journal writer instance and call the flush() method.

Requires swh-journal >= 1.2.0 (see swh-journal!229 (closed)).

Migrated from D8740 (view on Phabricator)

Merge request reports