Skip to content

Commit

Permalink
Add wrapper task output filtering.
Browse files Browse the repository at this point in the history
  • Loading branch information
riga committed Dec 19, 2024
1 parent e323f29 commit 1e8cf64
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion law/task/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
from law.util import (
no_value, abort, law_run, common_task_params, colored, uncolored, make_list, multi_match,
flatten, BaseStream, human_duration, patch_object, round_discrete, empty_context, perf_counter,
map_struct, mask_struct,
)
from law.logger import get_logger

Expand Down Expand Up @@ -711,7 +712,8 @@ def complete(self):
return all(task.complete() for task in flatten(reqs))

def output(self):
return self.input()
inputs = self.input()
return mask_struct(map_struct(bool, inputs), inputs) or []

def run(self):
return
Expand Down

0 comments on commit 1e8cf64

Please sign in to comment.