diff options
| author | Martin Czygan <martin.czygan@gmail.com> | 2021-06-10 16:16:23 +0200 |
|---|---|---|
| committer | Martin Czygan <martin.czygan@gmail.com> | 2021-06-10 16:16:23 +0200 |
| commit | 24f00c09b767ff1157b7e1548d938e18eb79dbf7 (patch) | |
| tree | 4786a7da10c8a8891ba6cee6eb94cdff19cdbbee /python | |
| parent | 0e2b9b61070f73fae110ad881f2a8b5d3da8a195 (diff) | |
| download | refcat-24f00c09b767ff1157b7e1548d938e18eb79dbf7.tar.gz refcat-24f00c09b767ff1157b7e1548d938e18eb79dbf7.zip | |
tasks: fix name
Diffstat (limited to 'python')
| -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) |