def test_correct_topic_models(self):
    topic_rights = topic_models.TopicRightsModel(id=self.TOPIC_ID, manager_ids=[], topic_is_published=True)
    topic_rights.commit(self.albert_id, 'topic rights model created', [{'cmd': 'create_new'}])
    topic_model = topic_models.TopicModel(id=self.TOPIC_ID, name='name', url_fragment='name-two', canonical_name='canonical_name', next_subtopic_id=1, language_code='en', subtopic_schema_version=0, story_reference_schema_version=0)
    topic_model.commit(self.albert_id, 'topic model created', self.DUMMY_COMMIT_CMDS)
    actual_output = self._run_one_off_job()
    expected_output = [['FOUND PARENT MODEL - TopicRightsSnapshotMetadataModel', 1], ['FOUND COMMIT LOGS - TopicSnapshotMetadataModel', 1], ['FOUND PARENT MODEL - TopicSnapshotMetadataModel', 1], ['FOUND COMMIT LOGS - TopicRightsSnapshotMetadataModel', 1]]
    self.assertItemsEqual(expected_output, actual_output)
def test_correct_topic_models(self):
    topic_rights = topic_models.TopicRightsModel(id=self.TOPIC_ID, manager_ids=[], topic_is_published=True)
    topic_rights.commit(self.albert_id, 'topic rights model created', [{'cmd': 'create_new'}])
    topic_model = topic_models.TopicModel(id=self.TOPIC_ID, name='name', url_fragment='name-two', canonical_name='canonical_name', next_subtopic_id=1, language_code='en', subtopic_schema_version=0, story_reference_schema_version=0)
    topic_model.commit(self.albert_id, 'topic model created', self.DUMMY_COMMIT_CMDS)
    actual_output = self._run_one_off_job()
    expected_output = [['FOUND PARENT MODEL - TopicRightsSnapshotMetadataModel', 1], ['FOUND COMMIT LOGS - TopicSnapshotMetadataModel', 1], ['FOUND PARENT MODEL - TopicSnapshotMetadataModel', 1], ['FOUND COMMIT LOGS - TopicRightsSnapshotMetadataModel', 1]]
    self.assertItemsEqual(expected_output, actual_output)