in transcoder/output/OutputManager.py [0:0]
def write_record(self, record_type_name, record):
"""For record of given type optionally lazily creation resources and write record"""
if self.lazy_create_resources is True and record_type_name not in self.existing_schemas:
schema = self.schema_definitions[record_type_name]
self.add_schema(schema)
self._write_record(record_type_name, record)