From 9b4639b20afe392df89cd514dc7e0a17069a5a3f Mon Sep 17 00:00:00 2001 From: Peter Giacomo Lombardo Date: Mon, 8 Apr 2019 16:05:55 +0200 Subject: [PATCH] Protect against short tuples --- instana/instrumentation/asynqp.py | 4 +++- tests/test_asynqp.py | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/instana/instrumentation/asynqp.py b/instana/instrumentation/asynqp.py index 5faeeefc..851edbb6 100644 --- a/instana/instrumentation/asynqp.py +++ b/instana/instrumentation/asynqp.py @@ -30,7 +30,9 @@ def publish_with_instana(wrapped, instance, argv, kwargs): scope.span.set_tag("exchange", instance.name) scope.span.set_tag("sort", "publish") scope.span.set_tag("address", host + ":" + str(port) ) - scope.span.set_tag("key", argv[1]) + + if len(argv) > 1 and argv[1] is not None: + scope.span.set_tag("key", argv[1]) rv = wrapped(*argv, **kwargs) except Exception as e: diff --git a/tests/test_asynqp.py b/tests/test_asynqp.py index b232aa0a..1569d607 100644 --- a/tests/test_asynqp.py +++ b/tests/test_asynqp.py @@ -66,7 +66,7 @@ def test_publish(self): @asyncio.coroutine def test(): with async_tracer.start_active_span('test'): - msg = asynqp.Message({'hello': 'world'}) + msg = asynqp.Message({'hello': 'world'}, content_type='application/json') self.exchange.publish(msg, 'routing.key') self.loop.run_until_complete(test())