diff --git a/sync/signals.py b/sync/signals.py index c067d03..e1eeb21 100644 --- a/sync/signals.py +++ b/sync/signals.py @@ -128,8 +128,9 @@ def save_model_log(users, model_operation, model_name, model_id, store_id): logger.info(f'*** creating ModelLogs for: {model_operation} {model_name} : {users}') - logs_to_create = [ - ModelLog( + with transaction.atomic(): + for user in users: + model_log = ModelLog( user=user, operation=model_operation, model_name=model_name, @@ -137,12 +138,7 @@ def save_model_log(users, model_operation, model_name, model_id, store_id): store_id=store_id, device_id=device_id ) - for user in users - # if user.can_synchronize - ] - - with transaction.atomic(): - ModelLog.objects.bulk_create(logs_to_create) + model_log.save() # with transaction.atomic(): # for user in users: