File tree Expand file tree Collapse file tree 2 files changed +4
-6
lines changed Expand file tree Collapse file tree 2 files changed +4
-6
lines changed Original file line number Diff line number Diff line change @@ -186,14 +186,12 @@ export class SqlDataQuery extends BaseSqlDataQuery {
186
186
}
187
187
188
188
evaluateRow ( table : SourceTableInterface , row : SqliteRow ) : EvaluationResult [ ] {
189
- const query = this ;
190
-
191
189
return this . evaluateRowWithOptions ( {
192
190
table,
193
191
row,
194
- bucketIds ( tables ) {
195
- const bucketParameters = query . filter . filterRow ( tables ) ;
196
- return bucketParameters . map ( ( params ) => getBucketId ( query . descriptorName , query . bucketParameters , params ) ) ;
192
+ bucketIds : ( tables ) => {
193
+ const bucketParameters = this . filter . filterRow ( tables ) ;
194
+ return bucketParameters . map ( ( params ) => getBucketId ( this . descriptorName , this . bucketParameters , params ) ) ;
197
195
}
198
196
} ) ;
199
197
}
Original file line number Diff line number Diff line change @@ -109,7 +109,7 @@ export const syncRulesSchema: ajvModule.Schema = {
109
109
}
110
110
}
111
111
} ,
112
- required : [ ] ,
112
+ anyOf : [ { required : [ 'bucket_definitions' ] } , { required : [ 'streams' ] } ] ,
113
113
additionalProperties : false
114
114
} as const ;
115
115
You can’t perform that action at this time.
0 commit comments