@@ -114,7 +114,8 @@ def _multi_load(self, keys, object_type, includes, nested_object_types):
114
114
if results [i ] is None :
115
115
self ._known_missing_ids .add (ids_of_not_existing_object [i ])
116
116
continue
117
- self ._convert_and_save_entity (ids_of_not_existing_object [i ], results [i ], object_type , nested_object_types )
117
+ self ._convert_and_save_entity (ids_of_not_existing_object [i ], results [i ], object_type ,
118
+ nested_object_types )
118
119
self .save_includes (response_includes )
119
120
return [None if key in self ._known_missing_ids else self ._entities_by_key [
120
121
key ] if key in self ._entities_by_key else None for key in keys ]
@@ -203,8 +204,8 @@ def delete(self, key_or_entity):
203
204
self ._defer_commands .add (commands_data .DeleteCommandData (key_or_entity ))
204
205
205
206
def assert_no_non_unique_instance (self , entity , key ):
206
- if not (key is None or key .endswith ("/" ) or key not in self ._entities_by_key or self . _entities_by_key [
207
- key ] is entity ):
207
+ if not (key is None or key .endswith ("/" ) or key not in self ._entities_by_key
208
+ or self . _entities_by_key [ key ] is entity ):
208
209
raise exceptions .NonUniqueObjectException (
209
210
"Attempted to associate a different object with id '{0}'." .format (key ))
210
211
@@ -310,8 +311,8 @@ def _prepare_for_puts_commands(self, data):
310
311
key = self ._entities_and_metadata [entity ]["key" ]
311
312
metadata = self ._entities_and_metadata [entity ]["metadata" ]
312
313
etag = None
313
- if self .advanced .use_optimistic_concurrency or self . _entities_and_metadata [ entity ][
314
- "force_concurrency_check" ]:
314
+ if self .advanced .use_optimistic_concurrency \
315
+ or self . _entities_and_metadata [ entity ][ "force_concurrency_check" ]:
315
316
etag = self ._entities_and_metadata [entity ]["etag" ] or metadata .get ("@etag" , Utils .empty_etag ())
316
317
data .entities .append (entity )
317
318
if key is not None :
0 commit comments