.

openedx-unsupported · Jun 7, 2018 · e75c441 · e75c441
1 parent 693e34c
commit e75c441
Showing 1 changed file with 9 additions and 8 deletions.
diff --git a/edx/analytics/tasks/common/spark.py b/edx/analytics/tasks/common/spark.py
@@ -176,14 +176,15 @@ class PathSelectionTaskSpark(EventLogSelectionDownstreamMixin, luigi.WrapperTask
     )
 
     def requires(self):
-        if not self.targets:
-            if self.pyspark_logger:
-                self.pyspark_logger.warn("PathSelectionTaskSpark=> targets not found, refreshing!")
-            self.targets = self._get_targets()
-        else:
-            if self.pyspark_logger:
-                self.pyspark_logger.warn("PathSelectionTaskSpark=> targets already exist")
-        return self.targets
+        return self._get_targets()
+        # if not self.targets:
+        #     if self.pyspark_logger:
+        #         self.pyspark_logger.warn("PathSelectionTaskSpark=> targets not found, refreshing!")
+        #     self.targets = self._get_targets()
+        # else:
+        #     if self.pyspark_logger:
+        #         self.pyspark_logger.warn("PathSelectionTaskSpark=> targets already exist")
+        # return self.targets
 
     def _get_targets(self):
         input = PathSelectionByDateIntervalTask(