class BulkUpdate(BulkUD):
"""BulkUD which handles UPDATEs."""
- def __init__(self, query, values):
+ def __init__(self, query, values, update_kwargs):
super(BulkUpdate, self).__init__(query)
- self.query._no_select_modifiers("update")
self.values = values
+ self.update_kwargs = update_kwargs
@classmethod
- def factory(cls, query, synchronize_session, values):
+ def factory(cls, query, synchronize_session, values, update_kwargs):
return BulkUD._factory({
"evaluate": BulkUpdateEvaluate,
"fetch": BulkUpdateFetch,