Broken python3 gluish TSV unicode

README.md

Do the whole thing:

PYTHONPATH='.' luigi --module small Small --local-scheduler

bad_fix.patch

diff --git a/gluish/format.py b/gluish/format.py
index 40ddf64..06872fb 100644
--- a/gluish/format.py
+++ b/gluish/format.py
@@ -59,7 +59,7 @@ def write_tsv(output_stream, *tup):
     Write argument list in `tup` out as a tab-separeated row to the stream.
     """
     value = '\t'.join([s for s in tup]) + '\n'
-    output_stream.write(str(value))
+    output_stream.write(value.encode('utf8'))
 
 
 def iter_tsv(input_stream, cols=None):
@@ -83,10 +83,10 @@ def iter_tsv(input_stream, cols=None):
                 for c in cols]
         Record = collections.namedtuple('Record', cols)
         for line in input_stream:
-            yield Record._make(str(line).rstrip('\n').split('\t'))
+            yield Record._make(line.decode('utf8').rstrip('\n').split('\t'))
     else:
         for line in input_stream:
-            yield tuple(str(line).rstrip('\n').split('\t'))
+            yield tuple(line.decode('utf8').rstrip('\n').split('\t'))
 
 
 class TSVFormat(luigi.format.Format):

input_sample.tsv

small.py

import luigi
from gluish.format import TSV

class SampleFile(luigi.ExternalTask):

    file_name = luigi.Parameter(default="input_sample.tsv")

    def output(self):
        return luigi.LocalTarget(self.file_name, format=TSV)

class Small(luigi.Task):

    def requires(self):
        return SampleFile()

    def run(self):
        with self.input().open() as in_file, self.output().open('w') as out_file:
            for row in in_file.iter_tsv(
                    cols=('col1', 'col2', 'col3')):
                out_file.write_tsv(row.col2, row.col3)

    def output(self):
        return luigi.LocalTarget('output.tsv', format=TSV)