async def process_gossip(self, chan_anns, node_anns, chan_upds):
    (await self.channel_db.data_loaded.wait())
    self.logger.debug(f'process_gossip {len(chan_anns)} {len(node_anns)} {len(chan_upds)}')

    def process_chan_anns():
        for payload in chan_anns:
            self.channel_db.verify_channel_announcement(payload)
        self.channel_db.add_channel_announcements(chan_anns)
    (await run_in_thread(process_chan_anns))

    def process_node_anns():
        for payload in node_anns:
            self.channel_db.verify_node_announcement(payload)
        self.channel_db.add_node_announcements(node_anns)
    (await run_in_thread(process_node_anns))
    categorized_chan_upds = (await run_in_thread(partial(self.channel_db.add_channel_updates, chan_upds, max_age=self.max_age)))
    orphaned = categorized_chan_upds.orphaned
    if orphaned:
        self.logger.info(f'adding {len(orphaned)} unknown channel ids')
        orphaned_ids = [c['short_channel_id'] for c in orphaned]
        (await self.add_new_ids(orphaned_ids))
    if categorized_chan_upds.good:
        self.logger.debug(f'on_channel_update: {len(categorized_chan_upds.good)}/{len(chan_upds)}')
async def process_gossip(self, chan_anns, node_anns, chan_upds):
    (await self.channel_db.data_loaded.wait())
    self.logger.debug(f'process_gossip {len(chan_anns)} {len(node_anns)} {len(chan_upds)}')

    def process_chan_anns():
        for payload in chan_anns:
            self.channel_db.verify_channel_announcement(payload)
        self.channel_db.add_channel_announcements(chan_anns)
    (await run_in_thread(process_chan_anns))

    def process_node_anns():
        for payload in node_anns:
            self.channel_db.verify_node_announcement(payload)
        self.channel_db.add_node_announcements(node_anns)
    (await run_in_thread(process_node_anns))
    categorized_chan_upds = (await run_in_thread(partial(self.channel_db.add_channel_updates, chan_upds, max_age=self.max_age)))
    orphaned = categorized_chan_upds.orphaned
    if orphaned:
        self.logger.info(f'adding {len(orphaned)} unknown channel ids')
        orphaned_ids = [c['short_channel_id'] for c in orphaned]
        (await self.add_new_ids(orphaned_ids))
    if categorized_chan_upds.good:
        self.logger.debug(f'on_channel_update: {len(categorized_chan_upds.good)}/{len(chan_upds)}')