diff options
| -rw-r--r-- | python/refcat/tasks.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/refcat/tasks.py b/python/refcat/tasks.py index 0d01a59..692cc05 100644 --- a/python/refcat/tasks.py +++ b/python/refcat/tasks.py @@ -1234,14 +1234,14 @@ class BrefSortedByWorkID(Refcat): return Bref() def run(self): - shellout(""" + output = shellout(""" zstdcat -T0 {bref} | skate-map -B -m ff -x source_work_ident | LC_ALL=C sort -T {tmpdir} -S25% -k1,1 --parallel 4 | zstd -c -T0 > {output} """, tmpdir=self.tmpdir, bref=self.input().path) - luigi.LocalTarget(tmpf).move(self.output().path) + luigi.LocalTarget(output).move(self.output().path) def output(self): return luigi.LocalTarget(path=self.path(ext="json.zst"), format=Zstd) @@ -1262,7 +1262,7 @@ class RefsByWorkID(Refcat): zstd -c -T0 > {output} """, input=self.input().path) - luigi.LocalTarget(tmpf).move(self.output().path) + luigi.LocalTarget(output).move(self.output().path) def output(self): return luigi.LocalTarget(path=self.path(ext="tsv.zst"), format=Zstd) |