From 24f00c09b767ff1157b7e1548d938e18eb79dbf7 Mon Sep 17 00:00:00 2001 From: Martin Czygan Date: Thu, 10 Jun 2021 16:16:23 +0200 Subject: tasks: fix name --- python/refcat/tasks.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'python') 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) -- cgit v1.2.3