Skip to content

Commit de45952

Browse files
committed
PFM-684 Adds a partition attribute to the filter
This will allow users of the action processor to partition their queries by any arbitrary value, not just the date and time.
1 parent eb57bd9 commit de45952

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/scala/com/intenthq/action_processor/integrations/feeds/FeedContext.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@ import com.intenthq.embeddings.Mapping
66

77
import java.time.{LocalDate, LocalTime}
88

9-
case class FeedFilter(date: Option[LocalDate], time: Option[LocalTime])
9+
case class FeedFilter(date: Option[LocalDate], time: Option[LocalTime], partition: Map[String, String])
1010
object FeedFilter {
11-
val empty: FeedFilter = FeedFilter(None, None)
11+
val empty: FeedFilter = FeedFilter(None, None, Map.empty)
1212
}
1313
case class FeedContext[F[_]](embeddings: Option[Mapping[String, List[String], F]],
1414
filter: FeedFilter,

src/test/scala/com/intenthq/action_processor/integrations/TestDefaults.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ object TestDefaults {
1616
levels = 4
1717
)
1818

19-
val feedFilter: FeedFilter = FeedFilter(None, None)
19+
val feedFilter: FeedFilter = FeedFilter.empty
2020

2121
def feedContext[F[_]]: FeedContext[F] =
2222
FeedContext[F](None, feedFilter, mapDbSettings, None)

0 commit comments

Comments
 (0)