Merge pull request #1439 from twitter/ggonzalez/fix_readPathsFor

Fix `readPathsFor` to use the `tz` argument
twitter · Sep 16, 2015 · 0a0cb1d · 0a0cb1d
2 parents 472e6c9 + d50d644
commit 0a0cb1d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/scalding-core/src/main/scala/com/twitter/scalding/TimePathedSource.scala b/scalding-core/src/main/scala/com/twitter/scalding/TimePathedSource.scala
@@ -46,8 +46,8 @@ object TimePathedSource {
    * Gives all read paths in the given daterange.
    */
   def readPathsFor(pattern: String, dateRange: DateRange, tz: TimeZone): Iterable[String] = {
-    TimePathedSource.stepSize(pattern, DateOps.UTC) match {
-      case Some(duration) => allPathsWithDuration(pattern, duration, dateRange, DateOps.UTC)
+    TimePathedSource.stepSize(pattern, tz) match {
+      case Some(duration) => allPathsWithDuration(pattern, duration, dateRange, tz)
       case None => sys.error(s"No suitable step size for pattern: $pattern")
     }
   }