diff options
| -rw-r--r-- | python/refcat/tasks.py | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/python/refcat/tasks.py b/python/refcat/tasks.py index 61be606..efb683e 100644 --- a/python/refcat/tasks.py +++ b/python/refcat/tasks.py @@ -1287,7 +1287,12 @@ class BrefCombined(Refcat): } def run(self): - raise NotImplementedError('todo') + output = shellout(""" + skate-reduce -m unmatched -B <(zstdcat -T0 {matched}) -R <(zstdcat -T0 {refs}) > {output} + """, + matched=self.input().get("matched").path, + refs=self.input().get("refs").path) + luigi.LocalTarget(output).move(self.output().path) def output(self): return luigi.LocalTarget(path=self.path(ext="json.zst"), format=Zstd) |