diff --git a/app/commons/kafka_producer.py b/app/commons/kafka_producer.py index c0909bd..f021905 100644 --- a/app/commons/kafka_producer.py +++ b/app/commons/kafka_producer.py @@ -118,6 +118,7 @@ async def create_activity_log(self, source_node: dict, schema_name: str, operato 'user': operator, 'imported_from': '', 'changes': [], + 'network_origin': 'unknown', } byte_message = await self._validate_message(schema_name, message) diff --git a/app/commons/metadata.items.activity.avsc b/app/commons/metadata.items.activity.avsc index 01a4c73..bd7059d 100644 --- a/app/commons/metadata.items.activity.avsc +++ b/app/commons/metadata.items.activity.avsc @@ -68,6 +68,10 @@ "values": "string" } } + }, + { + "name": "network_origin", + "type": "string" } ] } diff --git a/pyproject.toml b/pyproject.toml index 810efdc..8a59e3a 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [tool.poetry] name = "service_upload" -version = "2.2.11" +version = "2.2.12" description = "" authors = ["Indoc Research"]