Skip to content

Commit de42337

Browse files
Fix: Set ValidationWorkflow as a WrapperTask (#54)
1 parent 74a05cb commit de42337

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

data_validation_framework/task.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -707,7 +707,7 @@ def _process(self, df, *args, **kwargs):
707707
return df
708708

709709

710-
class ValidationWorkflow(SetValidationTask):
710+
class ValidationWorkflow(SetValidationTask, luigi.WrapperTask):
711711
"""Class to define and process a validation workflow."""
712712

713713
report_path = OptionalStrParameter(

tests/test_task.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2520,7 +2520,10 @@ class TestTask1(task.SkippableMixin(), luigi.Task):
25202520
):
25212521
TestTask1()
25222522

2523-
class TestTask2(task.SkippableMixin(), task.ValidationWorkflow):
2523+
class TestTask2(
2524+
task.SkippableMixin(),
2525+
task.ValidationWorkflow,
2526+
): # pylint: disable=too-many-ancestors
25242527
pass
25252528

25262529
with pytest.raises(

0 commit comments

Comments
 (0)