Skip to content

Commit

Permalink
Add comment 3
Browse files Browse the repository at this point in the history
  • Loading branch information
petyos committed Jan 29, 2024
1 parent 4900489 commit bcbd399
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions driven/storage/adapter.go
Original file line number Diff line number Diff line change
Expand Up @@ -359,6 +359,8 @@ func (a *Adapter) DeleteLegacyEvents() error {
} */
// DeleteLegacyEventsByIDss deletes all items by dataSourceEventIds
func (a *Adapter) DeleteLegacyEventsByIDs(context TransactionContext, dataSourceEventIds []string) error {

//PS - check the format in the database. It is "item.dataSourceEventId"
filter := bson.D{
primitive.E{Key: "dataSourceEventId", Value: primitive.M{"$in": dataSourceEventIds}},
}
Expand Down

0 comments on commit bcbd399

Please sign in to comment.