|
|
|
@ -119,6 +119,7 @@ def save_model_log(users, model_operation, model_name, model_id, store_id): |
|
|
|
with transaction.atomic(): |
|
|
|
with transaction.atomic(): |
|
|
|
created_logs = [] |
|
|
|
created_logs = [] |
|
|
|
for user in users: |
|
|
|
for user in users: |
|
|
|
|
|
|
|
if user.can_synchronize: |
|
|
|
# logger.info(f'Creating ModelLog for user {user.id} - user exists: {User.objects.filter(id=user.id).exists()}') |
|
|
|
# logger.info(f'Creating ModelLog for user {user.id} - user exists: {User.objects.filter(id=user.id).exists()}') |
|
|
|
model_log = ModelLog( |
|
|
|
model_log = ModelLog( |
|
|
|
user=user, |
|
|
|
user=user, |
|
|
|
@ -133,11 +134,11 @@ def save_model_log(users, model_operation, model_name, model_id, store_id): |
|
|
|
created_logs.append(model_log.id) |
|
|
|
created_logs.append(model_log.id) |
|
|
|
|
|
|
|
|
|
|
|
# Immediate verification within transaction |
|
|
|
# Immediate verification within transaction |
|
|
|
immediate_count = ModelLog.objects.filter(id__in=created_logs).count() |
|
|
|
# immediate_count = ModelLog.objects.filter(id__in=created_logs).count() |
|
|
|
# logger.info(f'*** Within transaction: Created {len(created_logs)}, found {immediate_count}') |
|
|
|
# logger.info(f'*** Within transaction: Created {len(created_logs)}, found {immediate_count}') |
|
|
|
|
|
|
|
|
|
|
|
# Verification after transaction commits |
|
|
|
# Verification after transaction commits |
|
|
|
persisted_count = ModelLog.objects.filter(id__in=created_logs).count() |
|
|
|
# persisted_count = ModelLog.objects.filter(id__in=created_logs).count() |
|
|
|
# logger.info(f'*** After transaction: Created {len(created_logs)}, persisted {persisted_count}') |
|
|
|
# logger.info(f'*** After transaction: Created {len(created_logs)}, persisted {persisted_count}') |
|
|
|
|
|
|
|
|
|
|
|
except Exception as e: |
|
|
|
except Exception as e: |
|
|
|
|