@@ -49,25 +49,25 @@ def get_key(obj):
49
49
new_obj .id = old_obj .id
50
50
existing_objs .append (new_obj )
51
51
52
- if skip_creates is False :
53
- db_class .objects .bulk_create (new_objs , batch_size = batch_size )
54
-
55
- if skip_updates is False :
56
- db_class .objects .bulk_update (existing_objs , fields = fields , batch_size = batch_size )
52
+ if skip_creates is False :
53
+ db_class .objects .bulk_create (new_objs , batch_size = batch_size )
54
+
55
+ if skip_updates is False :
56
+ db_class .objects .bulk_update (existing_objs , fields = fields , batch_size = batch_size )
57
57
58
- if skip_deletes is False :
59
- # delete stale objects
60
- objs .filter (pk__in = [_ .pk for _ in list (obj_dict .values ())]).delete ()
58
+ if skip_deletes is False :
59
+ # delete stale objects
60
+ objs .filter (pk__in = [_ .pk for _ in list (obj_dict .values ())]).delete ()
61
61
62
- assert len (existing_objs ) == len (new_models ) - len (new_objs )
62
+ assert len (existing_objs ) == len (new_models ) - len (new_objs )
63
63
64
- stats = {"created" : len (new_objs ), "updated" : len (new_models ) - len (new_objs ), "deleted" : len (obj_dict )}
64
+ stats = {"created" : len (new_objs ), "updated" : len (new_models ) - len (new_objs ), "deleted" : len (obj_dict )}
65
65
66
- logger .debug (
67
- "{}: {} created, {} updated, {} deleted." .format (
68
- db_class .__name__ , stats ["created" ], stats ["updated" ], stats ["deleted" ]
66
+ logger .debug (
67
+ "{}: {} created, {} updated, {} deleted." .format (
68
+ db_class .__name__ , stats ["created" ], stats ["updated" ], stats ["deleted" ]
69
+ )
69
70
)
70
- )
71
71
72
72
return {"stats" : stats }
73
73
0 commit comments