aboutsummaryrefslogtreecommitdiffstats
path: root/python
diff options
context:
space:
mode:
Diffstat (limited to 'python')
-rw-r--r--python/refcat/tasks.py15
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)
#