JournalClient: add a stop_at_eof boolean to read the log only once
Closed
requested to merge generated-differential-D2718-source into generated-differential-D2718-target
3 unresolved threads
Migrated from D2718 (view on Phabricator)
Merge request reports
Activity
Filter activity
171 176 if not messages: 172 177 continue 173 178 174 # Process messages and add the successfully processed ones to the 175 # message counter. 176 nb_messages += self.handle_messages(messages, worker_fn) 179 nb_processed, at_eof = self.handle_messages(messages, worker_fn) 48 48 client.process(worker_fn) 49 49 50 50 worker_fn.assert_called_once_with({'revision': [rev.to_dict()]}) 51 52 53 def test_client_eof( 54 kafka_prefix: str, 55 kafka_server: Tuple[Popen, int]): 199 210 worker_fn(dict(objects)) 200 211 self.consumer.commit() 201 212 202 return nb_processed 213 at_eof = (self.stop_on_eof and all( 214 (tp.topic, tp.partition) in self.eof_reached 215 for tp in self.consumer.assignment() Build was aborted
Link to build: https://jenkins.softwareheritage.org/job/DJNL/job/tox/333/ See console output for more information: https://jenkins.softwareheritage.org/job/DJNL/job/tox/333/console
Build has FAILED
Link to build: https://jenkins.softwareheritage.org/job/DJNL/job/tox/334/ See console output for more information: https://jenkins.softwareheritage.org/job/DJNL/job/tox/334/console
Please register or sign in to reply