Merge 0dc2f6837c1e6fd2be4c0ac8227f4e03c5e1fefc into fb54d8b54984f89f7dba90a18e7c3048421464c3

This commit is contained in:
edmundpf 2023-05-22 17:41:35 -05:00 committed by GitHub
commit 1cdf1bed40
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -330,7 +330,7 @@ object ExternalDataSources {
DAL DAL
.readMostRecentSnapshotNoOlderThan( .readMostRecentSnapshotNoOlderThan(
UserInterestRelationSnapshotScalaDataset, UserInterestRelationSnapshotScalaDataset,
Days(7)).withRemoteReadPolicy(ExplicitLocation(ProcAtla)).toTypedPipe.collect { Days(14)).withRemoteReadPolicy(ExplicitLocation(ProcAtla)).toTypedPipe.collect {
case userInterestsRelationSnapshot: UserInterestsRelationSnapshot case userInterestsRelationSnapshot: UserInterestsRelationSnapshot
if userInterestsRelationSnapshot.interestType == "UTT" && if userInterestsRelationSnapshot.interestType == "UTT" &&
userInterestsRelationSnapshot.relation == InterestRelationType.NotInterested => userInterestsRelationSnapshot.relation == InterestRelationType.NotInterested =>