sync get improvements and logs

main
Laurent 3 weeks ago
parent 77b999fbb3
commit 7bf560a6a2
  1. 4
      sync/views.py

@ -287,7 +287,6 @@ class LogProcessingResult:
def process_logs(self, logs): def process_logs(self, logs):
"""Process logs to collect basic operations and handle grant/revoke efficiently.""" """Process logs to collect basic operations and handle grant/revoke efficiently."""
for log in logs: for log in logs:
self.last_log_date = log.date
try: try:
if log.operation in ['POST', 'PUT', 'RELATIONSHIP_SET']: if log.operation in ['POST', 'PUT', 'RELATIONSHIP_SET']:
data = get_serialized_data_by_id(log.model_name, log.model_id) data = get_serialized_data_by_id(log.model_name, log.model_id)
@ -324,7 +323,10 @@ class LogProcessingResult:
self.shared_relationship_sets[log.model_name][log.model_id] = data self.shared_relationship_sets[log.model_name][log.model_id] = data
elif log.operation == 'SHARED_RELATIONSHIP_REMOVED': elif log.operation == 'SHARED_RELATIONSHIP_REMOVED':
self.shared_relationship_removals[log.model_name].append(log.data_identifier_dict()) self.shared_relationship_removals[log.model_name].append(log.data_identifier_dict())
self.last_log_date = log.date # set dates after having retrieved informations
except ObjectDoesNotExist: except ObjectDoesNotExist:
logger.warning(f'log processing failed, unable to find {log.model_name} : {log.model_id}')
pass pass
# Convert updates dict to list for each model # Convert updates dict to list for each model

Loading…
Cancel
Save