From 072981f1eb13a35659f327b881ba00ba9f3f4ddd Mon Sep 17 00:00:00 2001
From: marcsello <punkosdmarcell@rocketmail.com>
Date: Thu, 19 Aug 2021 03:30:42 +0200
Subject: [PATCH] Added announcement

---
 storage_service/views/object_view.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/storage_service/views/object_view.py b/storage_service/views/object_view.py
index 0580375..48e6591 100644
--- a/storage_service/views/object_view.py
+++ b/storage_service/views/object_view.py
@@ -6,6 +6,7 @@ from marshmallow import ValidationError
 from utils import storage
 from schemas import DescriptionSchema
 import opentracing
+from utils import magic_amqp
 
 
 class ObjectView(FlaskView):
@@ -70,6 +71,9 @@ class ObjectView(FlaskView):
             except ResponseError:  # TODO: Check if object already exists... somehow
                 raise
 
+        with opentracing.tracer.start_active_span('announceSampleReady'):
+            magic_amqp.publish({"tag": description['tag']})  # publish sample-ready, so that cnn can start working
+
         return jsonify({"status": "200"}), 200  # TODO: 200 should be OK but that would be inconsistent with the errors
 
     def get(self, tag: str):