e4d313478124e00a931ec40ab25643accad88641,beancount_import/source/generic_importer_source.py,ImporterSource,prepare,#ImporterSource#,55

Before Change

            for entry in f_entries:
                hash_ = self._hash_entry(entry, frozenset(["filename","lineno"]))
                // skip the existing entries from other statements
                if hash_ in entries: continue
                // If the entry exists in the journal, skip
                if self._is_existing(journal, entry): continue
                // add importer name as sorce description to source postings
                self._add_description(entry)
                // balance amount
                self.balance_amounts(entry)
                hashed_entries[hash_] = entry
            entries = {**entries, **hashed_entries}

        results.add_pending_entries(
            [ImportResult(entry.date, [entry], None)

After Change

                entries[hash_].extend(hashed_entries[hash_][n:])

        uncleared_entries = defaultdict(list)
        for hash_ in entries:
            // number of matching cleared entries in journal
            n = len(similar_entries_in_journal(entries[hash_][0],
                                               journal.entries,
                                               self.comparator))
            // If journal has n cleared entries for this hash, pick remaining
            for entry in entries[hash_][n:]:
                // add importer name as sorce description to source postings
                self._add_description(entry)
                // balance amount
                self.balance_amounts(entry)
                uncleared_entries[hash_].append(entry)

        results.add_pending_entries(
            [ImportResult(entry.date, [entry], None)
                for entry in itertools.chain.from_iterable(uncleared_entries.values())
            ]

Instances