Skip to content

Commit 643f7a1

Browse files
lrafeeilrafeei
committed
Revert library names to lowercase
1 parent b5f6c2f commit 643f7a1

File tree

15 files changed

+224
-226
lines changed

15 files changed

+224
-226
lines changed

‎newrelic/api/opentelemetry.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -306,12 +306,12 @@ def _messagequeue_attribute_mapping(self):
306306

307307
# Logic for Pika/RabbitMQ
308308
span_obj_attrs = {
309-
"library": self.attributes.get("messaging.system").capitalize(),
309+
"library": self.attributes.get("messaging.system"),
310310
"destination_name": name, # OTel's format for this is "name operation"
311311
}
312312

313313
# Keep this to simplify Transaction naming logic later on
314-
if span_obj_attrs["library"] == "Rabbitmq":
314+
if span_obj_attrs["library"] == "rabbitmq":
315315
# In RabbitMQ, destination_type is always Exchange and
316316
# destination_name is actually stored in the span name.
317317
# messaging.destination stores the task_name (such as
@@ -326,7 +326,7 @@ def _messagequeue_attribute_mapping(self):
326326
}
327327

328328
# Kafka Specific Logic
329-
if span_obj_attrs["library"] == "Kafka":
329+
if span_obj_attrs["library"] == "kafka":
330330
span_obj_attrs.update({
331331
"transport_type": "Kafka",
332332
"destination_type": "Topic",
@@ -345,7 +345,7 @@ def _messagequeue_attribute_mapping(self):
345345
for server_name in bootstrap_servers:
346346
produce_or_consume = "Produce" if self.kind == otel_api_trace.SpanKind.PRODUCER else "Consume"
347347
self.nr_transaction.record_custom_metric(
348-
f"MessageBroker/Kafka/Nodes/{server_name}/{produce_or_consume}/{span_obj_attrs['destination_name']}", 1
348+
f"MessageBroker/kafka/Nodes/{server_name}/{produce_or_consume}/{span_obj_attrs['destination_name']}", 1
349349
)
350350

351351
# Even if the attribute is set to None, it should rename
@@ -373,7 +373,7 @@ def _database_attribute_mapping(self):
373373
"host": self.attributes.get("net.peer.name") or self.attributes.get("server.address"),
374374
"database_name": self.attributes.get("db.name"),
375375
"port_path_or_id": self.attributes.get("net.peer.port") or self.attributes.get("server.port"),
376-
"product": self.attributes.get("db.system").capitalize(),
376+
"product": self.attributes.get("db.system"),
377377
}
378378
agent_attrs = {}
379379

@@ -384,7 +384,7 @@ def _database_attribute_mapping(self):
384384
operation, target = get_database_operation_target_from_statement(db_statement)
385385
target = target or self.attributes.get("db.mongodb.collection")
386386
span_obj_attrs.update({"operation": operation, "target": target})
387-
elif span_obj_attrs["product"] == "Dynamodb":
387+
elif span_obj_attrs["product"] == "dynamodb":
388388
region = self.attributes.get("cloud.region")
389389
operation = self.attributes.get("db.operation")
390390
target = self.attributes.get("aws.dynamodb.table_names", [None])[-1]
@@ -473,7 +473,7 @@ def __exit__(self, exc_type, exc_val, exc_tb):
473473
class Tracer(otel_api_trace.Tracer):
474474
def __init__(self, resource=None, instrumentation_library=None, *args, **kwargs):
475475
self.resource = resource
476-
self.instrumentation_library = instrumentation_library.split(".")[-1].capitalize()
476+
self.instrumentation_library = instrumentation_library.split(".")[-1]
477477

478478
def _create_web_transaction(self, nr_headers=None):
479479
if "nr.wsgi.environ" in self.attributes:
@@ -655,7 +655,7 @@ def start_span(
655655
# nor should we create a MessageTrace under it. We do,
656656
# however, want to add additional attributes from this span
657657
# into the existing transaction.
658-
if transaction and (getattr(self, "_create_consumer_trace", False) or (self.instrumentation_library != "Kafka")):
658+
if transaction and (getattr(self, "_create_consumer_trace", False) or (self.instrumentation_library != "kafka")):
659659
# If transaction already exists and the
660660
# _create_consumer_trace flag is set to True,
661661
# then create a MessageTrace under it.
@@ -675,10 +675,10 @@ def start_span(
675675
# a trace regardless of whether a transaction already existed.
676676
# This scenario should either create a transaction or use
677677
# the existing transaction and add additional attributes to it.
678-
if (self.instrumentation_library == "Kafka") or not getattr(self, "_create_consumer_trace", False):
678+
if (self.instrumentation_library == "kafka") or not getattr(self, "_create_consumer_trace", False):
679679
create_nr_trace = False
680680

681-
if self.instrumentation_library == "Kafka":
681+
if self.instrumentation_library == "kafka":
682682
# Whether a transaction exists or not, do not create a NR
683683
# trace for the case of a consumer span.
684684
create_nr_trace = False

‎tests/hybridagent_dynamodb/test_botocore_dynamodb.py‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -37,21 +37,21 @@
3737

3838

3939
_dynamodb_scoped_metrics = [
40-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/CreateTable", 1),
41-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/PutItem", 1),
42-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/GetItem", 1),
43-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/UpdateItem", 1),
44-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/Query", 1),
45-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/Scan", 1),
46-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/DeleteItem", 1),
47-
(f"Datastore/statement/Dynamodb/{TEST_TABLE}/DeleteTable", 1),
40+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/CreateTable", 1),
41+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/PutItem", 1),
42+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/GetItem", 1),
43+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/UpdateItem", 1),
44+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/Query", 1),
45+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/Scan", 1),
46+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/DeleteItem", 1),
47+
(f"Datastore/statement/dynamodb/{TEST_TABLE}/DeleteTable", 1),
4848
]
4949

5050
_dynamodb_rollup_metrics = [
5151
("Datastore/all", 8),
5252
("Datastore/allOther", 8),
53-
("Datastore/Dynamodb/all", 8),
54-
("Datastore/Dynamodb/allOther", 8),
53+
("Datastore/dynamodb/all", 8),
54+
("Datastore/dynamodb/allOther", 8),
5555
]
5656

5757

@@ -61,7 +61,7 @@ def test_dynamodb(account_id):
6161
if account_id:
6262
expected_aws_agent_attrs = {
6363
"cloud.resource_id": f"arn:aws:dynamodb:{AWS_REGION}:{account_id:012d}:table/{TEST_TABLE}",
64-
"db.system": "Dynamodb",
64+
"db.system": "dynamodb",
6565
}
6666

6767
@override_application_settings({"cloud.aws.account_id": account_id})

‎tests/hybridagent_kafkapython/test_consumer.py‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
def test_custom_metrics(get_consumer_record, topic, expected_broker_metrics):
3030
@validate_transaction_metrics(
3131
f"Named/{topic}",
32-
group="Message/Kafka/Topic",
32+
group="Message/kafka/Topic",
3333
custom_metrics=[*expected_broker_metrics],
3434
background_task=True,
3535
)
@@ -111,7 +111,7 @@ def _produce():
111111

112112
@validate_transaction_metrics(
113113
f"Named/{topic}",
114-
group="Message/Kafka/Topic",
114+
group="Message/kafka/Topic",
115115
rollup_metrics=[
116116
("Supportability/DistributedTrace/AcceptPayload/Success", None),
117117
("Supportability/TraceContext/TraceParent/Accept/Success", 1),
@@ -162,14 +162,14 @@ def _poll(*args, **kwargs):
162162

163163
@pytest.fixture
164164
def expected_broker_metrics(broker, topic):
165-
return [(f"MessageBroker/Kafka/Nodes/{server}/Consume/{topic}", 1) for server in broker]
165+
return [(f"MessageBroker/kafka/Nodes/{server}/Consume/{topic}", 1) for server in broker]
166166

167167

168168
@pytest.fixture
169169
def expected_producer_broker_metrics(broker, topic):
170-
return [(f"MessageBroker/Kafka/Nodes/{server}/Produce/{topic}", 1) for server in broker]
170+
return [(f"MessageBroker/kafka/Nodes/{server}/Produce/{topic}", 1) for server in broker]
171171

172172

173173
@pytest.fixture
174174
def expected_missing_broker_metrics(broker, topic):
175-
return [(f"MessageBroker/Kafka/Nodes/{server}/Consume/{topic}", None) for server in broker]
175+
return [(f"MessageBroker/kafka/Nodes/{server}/Consume/{topic}", None) for server in broker]

‎tests/hybridagent_kafkapython/test_producer.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424

2525
def test_trace_metrics(topic, send_producer_message, expected_broker_metrics):
2626

27-
scoped_metrics = [(f"MessageBroker/Kafka/Topic/Produce/Named/{topic}", 1)]
27+
scoped_metrics = [(f"MessageBroker/kafka/Topic/Produce/Named/{topic}", 1)]
2828
unscoped_metrics = scoped_metrics
2929

3030
@validate_transaction_metrics(
@@ -90,4 +90,4 @@ def test():
9090

9191
@pytest.fixture
9292
def expected_broker_metrics(broker, topic):
93-
return [(f"MessageBroker/Kafka/Nodes/{server}/Produce/{topic}", 1) for server in broker]
93+
return [(f"MessageBroker/kafka/Nodes/{server}/Produce/{topic}", 1) for server in broker]

‎tests/hybridagent_mysql/test_database.py‎

Lines changed: 42 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -33,32 +33,32 @@
3333

3434

3535
_test_execute_via_cursor_scoped_metrics = [
36-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
37-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
38-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
39-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
40-
("Datastore/operation/Mysql/drop", 2),
41-
("Datastore/operation/Mysql/create", 2),
42-
(f"Datastore/operation/Mysql/{DB_PROCEDURE}", 1),
36+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
37+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
38+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
39+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
40+
("Datastore/operation/mysql/drop", 2),
41+
("Datastore/operation/mysql/create", 2),
42+
(f"Datastore/operation/mysql/{DB_PROCEDURE}", 1),
4343
]
4444

4545
_test_execute_via_cursor_rollup_metrics = [
4646
("Datastore/all", 9),
4747
("Datastore/allOther", 9),
48-
("Datastore/Mysql/all", 9),
49-
("Datastore/Mysql/allOther", 9),
50-
("Datastore/operation/Mysql/select", 1),
51-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
52-
("Datastore/operation/Mysql/insert", 1),
53-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
54-
("Datastore/operation/Mysql/update", 1),
55-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
56-
("Datastore/operation/Mysql/delete", 1),
57-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
58-
(f"Datastore/operation/Mysql/{DB_PROCEDURE}", 1),
59-
("Datastore/operation/Mysql/drop", 2),
60-
("Datastore/operation/Mysql/create", 2),
61-
(f"Datastore/instance/Mysql/{instance_hostname(DB_SETTINGS['host'])}/{DB_SETTINGS['port']}", 9),
48+
("Datastore/mysql/all", 9),
49+
("Datastore/mysql/allOther", 9),
50+
("Datastore/operation/mysql/select", 1),
51+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
52+
("Datastore/operation/mysql/insert", 1),
53+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
54+
("Datastore/operation/mysql/update", 1),
55+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
56+
("Datastore/operation/mysql/delete", 1),
57+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
58+
(f"Datastore/operation/mysql/{DB_PROCEDURE}", 1),
59+
("Datastore/operation/mysql/drop", 2),
60+
("Datastore/operation/mysql/create", 2),
61+
(f"Datastore/instance/mysql/{instance_hostname(DB_SETTINGS['host'])}/{DB_SETTINGS['port']}", 9),
6262
]
6363

6464

@@ -125,32 +125,32 @@ def test_execute_via_cursor(table_name):
125125

126126

127127
_test_connect_using_alias_scoped_metrics = [
128-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
129-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
130-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
131-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
132-
("Datastore/operation/Mysql/drop", 2),
133-
("Datastore/operation/Mysql/create", 2),
134-
(f"Datastore/operation/Mysql/{DB_PROCEDURE}", 1),
128+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
129+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
130+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
131+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
132+
("Datastore/operation/mysql/drop", 2),
133+
("Datastore/operation/mysql/create", 2),
134+
(f"Datastore/operation/mysql/{DB_PROCEDURE}", 1),
135135
]
136136

137137
_test_connect_using_alias_rollup_metrics = [
138138
("Datastore/all", 9),
139139
("Datastore/allOther", 9),
140-
("Datastore/Mysql/all", 9),
141-
("Datastore/Mysql/allOther", 9),
142-
("Datastore/operation/Mysql/select", 1),
143-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
144-
("Datastore/operation/Mysql/insert", 1),
145-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
146-
("Datastore/operation/Mysql/update", 1),
147-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
148-
("Datastore/operation/Mysql/delete", 1),
149-
(f"Datastore/statement/Mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
150-
(f"Datastore/operation/Mysql/{DB_PROCEDURE}", 1),
151-
("Datastore/operation/Mysql/drop", 2),
152-
("Datastore/operation/Mysql/create", 2),
153-
(f"Datastore/instance/Mysql/{instance_hostname(DB_SETTINGS['host'])}/{DB_SETTINGS['port']}", 9),
140+
("Datastore/mysql/all", 9),
141+
("Datastore/mysql/allOther", 9),
142+
("Datastore/operation/mysql/select", 1),
143+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/select", 1),
144+
("Datastore/operation/mysql/insert", 1),
145+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/insert", 1),
146+
("Datastore/operation/mysql/update", 1),
147+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/update", 1),
148+
("Datastore/operation/mysql/delete", 1),
149+
(f"Datastore/statement/mysql/datastore_mysql_{DB_NAMESPACE}/delete", 1),
150+
(f"Datastore/operation/mysql/{DB_PROCEDURE}", 1),
151+
("Datastore/operation/mysql/drop", 2),
152+
("Datastore/operation/mysql/create", 2),
153+
(f"Datastore/instance/mysql/{instance_hostname(DB_SETTINGS['host'])}/{DB_SETTINGS['port']}", 9),
154154
]
155155

156156

‎tests/hybridagent_pika/test_distributed_tracing.py‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ def do_basic_publish(channel, queue_name, properties=None):
4040
_test_distributed_tracing_basic_publish_metrics = [
4141
("Supportability/TraceContext/Create/Success", 2),
4242
("Supportability/DistributedTrace/CreatePayload/Success", 2),
43-
(f"MessageBroker/Rabbitmq/Exchange/Produce/Named/{queue_name}", 2),
43+
(f"MessageBroker/rabbitmq/Exchange/Produce/Named/{queue_name}", 2),
4444
("DurationByCaller/Unknown/Unknown/Unknown/Unknown/all", 1),
4545
("DurationByCaller/Unknown/Unknown/Unknown/Unknown/allOther", 1),
4646
]
@@ -63,8 +63,8 @@ def do_basic_consume(channel, queue_name):
6363
# and not a MessageTransaction (from the channel.basic_consume call)
6464
# BG task to AMQP will make parent app an unknown transport_type.
6565
_test_distributed_tracing_basic_consume_rollup_metrics = [
66-
(f"MessageBroker/Rabbitmq/Exchange/Produce/Named/{queue_name}", None),
67-
(f"MessageBroker/Rabbitmq/Exchange/Consume/Named/{queue_name}", None),
66+
(f"MessageBroker/rabbitmq/Exchange/Produce/Named/{queue_name}", None),
67+
(f"MessageBroker/rabbitmq/Exchange/Consume/Named/{queue_name}", None),
6868
("Supportability/DistributedTrace/AcceptPayload/Success", None),
6969
("Supportability/TraceContext/TraceParent/Accept/Success", 1),
7070
("Supportability/TraceContext/Accept/Success", 1),
@@ -78,7 +78,7 @@ def do_basic_consume(channel, queue_name):
7878
f"{queue_name}",
7979
rollup_metrics=_test_distributed_tracing_basic_consume_rollup_metrics,
8080
background_task=True,
81-
group="Message/Rabbitmq/Exchange/Named",
81+
group="Message/rabbitmq/Exchange/Named",
8282
)
8383
def _test():
8484
channel.start_consuming()
@@ -125,8 +125,8 @@ def on_receive(ch, method, properties, msg):
125125

126126

127127
_test_distributed_tracing_basic_get_metrics = [
128-
("MessageBroker/Rabbitmq/Exchange/Produce/Named/Default", None),
129-
("MessageBroker/Rabbitmq/Exchange/Consume/Named/Default", None),
128+
("MessageBroker/rabbitmq/Exchange/Produce/Named/Default", None),
129+
("MessageBroker/rabbitmq/Exchange/Consume/Named/Default", None),
130130
("DurationByCaller/Unknown/Unknown/Unknown/Unknown/all", 1),
131131
("DurationByCaller/Unknown/Unknown/Unknown/Unknown/allOther", 1),
132132
]

‎tests/hybridagent_pika/test_pika_blocking_connection_consume_generator.py‎

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,9 @@
4949
}
5050

5151
_test_blocking_connection_consume_metrics = [
52-
(f"MessageBroker/Rabbitmq/Exchange/Produce/Named/{EXCHANGE}", None),
53-
(f"MessageBroker/Rabbitmq/Exchange/Consume/Named/{EXCHANGE}", 1),
54-
("MessageBroker/Rabbitmq/Exchange/Consume/Named/Unknown", None),
52+
(f"MessageBroker/rabbitmq/Exchange/Produce/Named/{EXCHANGE}", None),
53+
(f"MessageBroker/rabbitmq/Exchange/Consume/Named/{EXCHANGE}", 1),
54+
("MessageBroker/rabbitmq/Exchange/Consume/Named/Unknown", None),
5555
]
5656

5757

@@ -147,9 +147,9 @@ def test_blocking_connection_consume_exception_in_for_loop(producer):
147147

148148

149149
_test_blocking_connection_consume_empty_metrics = [
150-
(f"MessageBroker/Rabbitmq/Exchange/Produce/Named/{EXCHANGE}", None),
151-
(f"MessageBroker/Rabbitmq/Exchange/Consume/Named/{EXCHANGE}", None),
152-
("MessageBroker/Rabbitmq/Exchange/Consume/Named/Unknown", None),
150+
(f"MessageBroker/rabbitmq/Exchange/Produce/Named/{EXCHANGE}", None),
151+
(f"MessageBroker/rabbitmq/Exchange/Consume/Named/{EXCHANGE}", None),
152+
("MessageBroker/rabbitmq/Exchange/Consume/Named/Unknown", None),
153153
]
154154

155155

@@ -179,8 +179,8 @@ def test_blocking_connection_consume_exception_in_generator():
179179

180180

181181
_test_blocking_connection_consume_many_metrics = [
182-
(f"MessageBroker/Rabbitmq/Exchange/Produce/Named/{EXCHANGE}", None),
183-
(f"MessageBroker/Rabbitmq/Exchange/Consume/Named/{EXCHANGE}", 5),
182+
(f"MessageBroker/rabbitmq/Exchange/Produce/Named/{EXCHANGE}", None),
183+
(f"MessageBroker/rabbitmq/Exchange/Consume/Named/{EXCHANGE}", 5),
184184
]
185185

186186

@@ -248,7 +248,7 @@ def test_blocking_connection_consume_using_methods(producer):
248248
@validate_transaction_metrics(
249249
f"Named/{EXCHANGE}",
250250
background_task=True,
251-
group="Message/Rabbitmq/Exchange",
251+
group="Message/rabbitmq/Exchange",
252252
)
253253
@validate_tt_collector_json(message_broker_params=_message_broker_tt_params)
254254
def test_blocking_connection_consume_outside_txn(producer):
@@ -276,7 +276,7 @@ def test_blocking_connection_consume_many_outside_txn(produce_five):
276276
@validate_transaction_metrics(
277277
f"Named/{EXCHANGE}",
278278
background_task=True,
279-
group="Message/Rabbitmq/Exchange",
279+
group="Message/rabbitmq/Exchange",
280280
)
281281
@validate_tt_collector_json(message_broker_params=_message_broker_tt_params)
282282
def consume_it(consumer, up_next=None):
@@ -311,7 +311,7 @@ def consume_it(consumer, up_next=None):
311311
@validate_transaction_metrics(
312312
f"Named/{EXCHANGE}",
313313
background_task=True,
314-
group="Message/Rabbitmq/Exchange",
314+
group="Message/rabbitmq/Exchange",
315315
)
316316
@validate_tt_collector_json(message_broker_params=_message_broker_tt_params)
317317
def test_blocking_connection_consume_using_methods_outside_txn(producer):

0 commit comments

Comments
 (0)