diff --git a/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala b/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala index 729cb95d0..c4e434593 100644 --- a/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala +++ b/src/scala/com/twitter/simclusters_v2/scalding/embedding/common/ExternalDataSources.scala @@ -330,7 +330,7 @@ object ExternalDataSources { DAL .readMostRecentSnapshotNoOlderThan( UserInterestRelationSnapshotScalaDataset, - Days(7)).withRemoteReadPolicy(ExplicitLocation(ProcAtla)).toTypedPipe.collect { + Days(14)).withRemoteReadPolicy(ExplicitLocation(ProcAtla)).toTypedPipe.collect { case userInterestsRelationSnapshot: UserInterestsRelationSnapshot if userInterestsRelationSnapshot.interestType == "UTT" && userInterestsRelationSnapshot.relation == InterestRelationType.NotInterested =>