def process_incoming_rows(f, record_type=None):
    if (record_type and (not isinstance(record_type, bytes))):
        record_type = record_type.encode('utf-8')
    for line in f:
        if record_type:
            (yield (((line.rstrip() + b',') + record_type) + b'\n'))
        else:
            (yield line)
def process_incoming_rows(f, record_type=None):
    if (record_type and (not isinstance(record_type, bytes))):
        record_type = record_type.encode('utf-8')
    for line in f:
        if record_type:
            (yield (((line.rstrip() + b',') + record_type) + b'\n'))
        else:
            (yield line)