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):