diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/refcat/tasks.py | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/python/refcat/tasks.py b/python/refcat/tasks.py index 692cc05..234fc11 100644 --- a/python/refcat/tasks.py +++ b/python/refcat/tasks.py @@ -1239,8 +1239,8 @@ class BrefSortedByWorkID(Refcat): 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) + tmpdir=self.tmpdir, + bref=self.input().path) luigi.LocalTarget(output).move(self.output().path) def output(self): @@ -1276,6 +1276,17 @@ class BrefCombined(Refcat): This is basically a reduce step, where we group by work id (since the raw refs were already sorted by work id). """ + def requires(self): + return { + "refs": RefsByWorkID(), + "matched": BrefSortedByWorkID(), + } + + def run(self): + raise NotImplementedError('todo') + + def output(self): + return luigi.LocalTarget(path=self.path(ext="json.zst"), format=Zstd) # |