Merge 0dc2f6837c
into 72eda9a24f
This commit is contained in:
commit
f673c510b2
|
@ -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 =>
|
||||
|
|
Loading…
Reference in New Issue