tasks.py 文件源码

def _deferred(self):
        episodes = self._parse_episodes_from_feed()

        logging.debug('Relevant episodes found in RSS feed: %d', len(episodes))

        # Save all episodes we haven't stored yet
        for episode in episodes:
            logging.debug('Found episode: %s', episode)
            if self._get_existing_episode_from_database(episode) is None:
                try:
                    episode.save()
                    self._notify_user(episode)
                    logging.info('Saved episode: %s', episode)
                except IntegrityError:
                    logging.error('Could not save episode to database')