|
14 | 14 | from mongoengine.errors import (ValidationError, InvalidDocumentError, |
15 | 15 | LookUpError, FieldDoesNotExist) |
16 | 16 | from mongoengine.python_support import PY3, txt_type |
17 | | - |
18 | 17 | from mongoengine.base.common import get_document, ALLOW_INHERITANCE |
19 | 18 | from mongoengine.base.datastructures import ( |
20 | 19 | BaseDict, |
@@ -150,7 +149,6 @@ def __setattr__(self, name, value): |
150 | 149 | # Handle dynamic data only if an initialised dynamic document |
151 | 150 | if self._dynamic and not self._dynamic_lock: |
152 | 151 |
|
153 | | - field = None |
154 | 152 | if not hasattr(self, name) and not name.startswith('_'): |
155 | 153 | DynamicField = _import_class("DynamicField") |
156 | 154 | field = DynamicField(db_field=name) |
@@ -183,8 +181,8 @@ def __setattr__(self, name, value): |
183 | 181 | except AttributeError: |
184 | 182 | self__initialised = False |
185 | 183 | # Check if the user has created a new instance of a class |
186 | | - if (self._is_document and self__initialised |
187 | | - and self__created and name == self._meta.get('id_field')): |
| 184 | + if (self._is_document and self__initialised and |
| 185 | + self__created and name == self._meta.get('id_field')): |
188 | 186 | super(BaseDocument, self).__setattr__('_created', False) |
189 | 187 |
|
190 | 188 | super(BaseDocument, self).__setattr__(name, value) |
@@ -328,7 +326,7 @@ def to_mongo(self, use_db_field=True, fields=None): |
328 | 326 |
|
329 | 327 | if value is not None: |
330 | 328 |
|
331 | | - if isinstance(field, (EmbeddedDocumentField)): |
| 329 | + if isinstance(field, EmbeddedDocumentField): |
332 | 330 | if fields: |
333 | 331 | key = '%s.' % field_name |
334 | 332 | embedded_fields = [ |
@@ -417,10 +415,11 @@ def validate(self, clean=True): |
417 | 415 |
|
418 | 416 | def to_json(self, *args, **kwargs): |
419 | 417 | """Converts a document to JSON. |
420 | | - :param use_db_field: Set to True by default but enables the output of the json structure with the field names and not the mongodb store db_names in case of set to False |
| 418 | + :param use_db_field: Set to True by default but enables the output of the json structure with the field names |
| 419 | + and not the mongodb store db_names in case of set to False |
421 | 420 | """ |
422 | 421 | use_db_field = kwargs.pop('use_db_field', True) |
423 | | - return json_util.dumps(self.to_mongo(use_db_field), *args, **kwargs) |
| 422 | + return json_util.dumps(self.to_mongo(use_db_field), *args, **kwargs) |
424 | 423 |
|
425 | 424 | @classmethod |
426 | 425 | def from_json(cls, json_data, created=False): |
@@ -570,15 +569,15 @@ def _get_changed_fields(self, inspected=None): |
570 | 569 | continue |
571 | 570 | elif (isinstance(data, (EmbeddedDocument, DynamicEmbeddedDocument)) |
572 | 571 | and db_field_name not in changed_fields): |
573 | | - # Find all embedded fields that have been changed |
| 572 | + # Find all embedded fields that have been changed |
574 | 573 | changed = data._get_changed_fields(inspected) |
575 | 574 | changed_fields += ["%s%s" % (key, k) for k in changed if k] |
576 | 575 | elif (isinstance(data, (list, tuple, dict)) and |
577 | 576 | db_field_name not in changed_fields): |
578 | 577 | if (hasattr(field, 'field') and |
579 | 578 | isinstance(field.field, ReferenceField)): |
580 | 579 | continue |
581 | | - elif (isinstance(field, SortedListField) and field._ordering): |
| 580 | + elif isinstance(field, SortedListField) and field._ordering: |
582 | 581 | # if ordering is affected whole list is changed |
583 | 582 | if any(map(lambda d: field._ordering in d._changed_fields, data)): |
584 | 583 | changed_fields.append(db_field_name) |
@@ -621,18 +620,18 @@ def _delta(self): |
621 | 620 | else: |
622 | 621 | set_data = doc |
623 | 622 | if '_id' in set_data: |
624 | | - del(set_data['_id']) |
| 623 | + del set_data['_id'] |
625 | 624 |
|
626 | 625 | # Determine if any changed items were actually unset. |
627 | 626 | for path, value in set_data.items(): |
628 | 627 | if value or isinstance(value, (numbers.Number, bool)): |
629 | 628 | continue |
630 | 629 |
|
631 | | - # If we've set a value that ain't the default value dont unset it. |
| 630 | + # If we've set a value that ain't the default value don't unset it. |
632 | 631 | default = None |
633 | 632 | if (self._dynamic and len(parts) and parts[0] in |
634 | 633 | self._dynamic_fields): |
635 | | - del(set_data[path]) |
| 634 | + del set_data[path] |
636 | 635 | unset_data[path] = 1 |
637 | 636 | continue |
638 | 637 | elif path in self._fields: |
@@ -666,7 +665,7 @@ def _delta(self): |
666 | 665 | if default != value: |
667 | 666 | continue |
668 | 667 |
|
669 | | - del(set_data[path]) |
| 668 | + del set_data[path] |
670 | 669 | unset_data[path] = 1 |
671 | 670 | return set_data, unset_data |
672 | 671 |
|
@@ -821,7 +820,6 @@ def _build_index_spec(cls, spec): |
821 | 820 | parts = key.split('.') |
822 | 821 | if parts in (['pk'], ['id'], ['_id']): |
823 | 822 | key = '_id' |
824 | | - fields = [] |
825 | 823 | else: |
826 | 824 | fields = cls._lookup_field(parts) |
827 | 825 | parts = [] |
@@ -981,7 +979,7 @@ def _lookup_field(cls, parts): |
981 | 979 | if hasattr(getattr(field, 'field', None), 'lookup_member'): |
982 | 980 | new_field = field.field.lookup_member(field_name) |
983 | 981 | elif cls._dynamic and (isinstance(field, DynamicField) or |
984 | | - getattr(getattr(field, 'document_type'), '_dynamic')): |
| 982 | + getattr(getattr(field, 'document_type'), '_dynamic')): |
985 | 983 | new_field = DynamicField(db_field=field_name) |
986 | 984 | else: |
987 | 985 | # Look up subfield on the previous field or raise |
|
0 commit comments