Ensure BeamDataflowJobTask is init

clairemcginty · clairemcginty · commit 5d9d38df68f6 · 2019-05-08T14:49:59.000-04:00
diff --git a/luigi/contrib/beam_dataflow.py b/luigi/contrib/beam_dataflow.py
@@ -219,6 +219,7 @@ class BeamDataflowJobTask(MixinNaiveBulkComplete, luigi.Task):
     def __init__(self):
         if not isinstance(self.dataflow_params, DataflowParamKeys):
             raise ValueError("dataflow_params must be of type DataflowParamKeys")
+        super(BeamDataflowJobTask, self).__init__()
 
     @abstractmethod
     def dataflow_executable(self):
