diff --git a/edi_oca/models/edi_backend.py b/edi_oca/models/edi_backend.py index d688e95e08..6d422e8e5f 100644 --- a/edi_oca/models/edi_backend.py +++ b/edi_oca/models/edi_backend.py @@ -407,9 +407,7 @@ def _check_output_exchange_sync( :param skip_sent: ignore records that were already sent. """ # Generate output files - new_records = self.exchange_record_model.search( - self._output_new_records_domain(record_ids=record_ids) - ) + new_records = self._get_new_output_exchange_records(record_ids=record_ids) _logger.info( "EDI Exchange output sync: found %d new records to process.", len(new_records), @@ -440,6 +438,11 @@ def _check_output_exchange_sync( # TODO: run in job as well? self._exchange_output_check_state(rec) + def _get_new_output_exchange_records(self, record_ids=None): + return self.exchange_record_model.search( + self._output_new_records_domain(record_ids=record_ids) + ) + def _output_new_records_domain(self, record_ids=None): """Domain for output records needing output content generation.""" domain = [