From 895765ffa6ca34b9cb08dd0bb76e43efecde80bd Mon Sep 17 00:00:00 2001
From: Martin Czygan <martin.czygan@gmail.com>
Date: Thu, 10 Jun 2021 16:19:09 +0200
Subject: tasks: add stub

---
 python/refcat/tasks.py | 15 +++++++++++++--
 1 file 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)
 
 
 #
-- 
cgit v1.2.3