#131 EGON export
* finishes egon compatible (tested) data export * moves egon export into celery process * adds export of data in case of intervention recording * adds _RABBITMQ_ settings for intervention/settings.py * adds new dependency for requirements.txt
This commit is contained in:
@@ -13,6 +13,7 @@ from django.db.models.fields.files import FieldFile
|
||||
from django.urls import reverse
|
||||
from django.utils import timezone
|
||||
|
||||
from intervention.tasks import celery_export_to_egon
|
||||
from user.models import User
|
||||
from django.db import models, transaction
|
||||
from django.db.models import QuerySet
|
||||
@@ -131,9 +132,20 @@ class Intervention(BaseObject, ShareableObjectMixin, RecordableObjectMixin, Chec
|
||||
self.add_log_entry_to_compensations(log_entry)
|
||||
return log_entry
|
||||
|
||||
def send_data_to_egon(self):
|
||||
""" Performs the export to rabbitmq of this intervention's data
|
||||
|
||||
FOLLOWING BACKWARDS COMPATIBILITY LOGIC
|
||||
|
||||
Returns:
|
||||
|
||||
"""
|
||||
celery_export_to_egon.delay(self.id)
|
||||
|
||||
def set_recorded(self, user: User) -> UserActionLogEntry:
|
||||
log_entry = super().set_recorded(user)
|
||||
self.add_log_entry_to_compensations(log_entry)
|
||||
self.send_data_to_egon()
|
||||
return log_entry
|
||||
|
||||
def add_log_entry_to_compensations(self, log_entry: UserActionLogEntry):
|
||||
|
||||
Reference in New Issue
Block a user