[MegaLinter] Apply linters fixes

Author: TimPansino

newrelic/core/infinite_tracing_pb2.py

@@ -21,8 +21,8 @@
 
 # Import appropriate generated pb2 file for protobuf version
 if PROTOBUF_VERSION >= (5,):
-    from newrelic.core.infinite_tracing_v5_pb2 import AttributeValue, RecordStatus, Span, SpanBatch  # noqa: F401
+    from newrelic.core.infinite_tracing_v5_pb2 import AttributeValue, RecordStatus, Span, SpanBatch
 elif PROTOBUF_VERSION >= (4,):
-    from newrelic.core.infinite_tracing_v4_pb2 import AttributeValue, RecordStatus, Span, SpanBatch  # noqa: F401
+    from newrelic.core.infinite_tracing_v4_pb2 import AttributeValue, RecordStatus, Span, SpanBatch
 else:
     from newrelic.core.infinite_tracing_v3_pb2 import AttributeValue, RecordStatus, Span, SpanBatch  # noqa: F401

tests/agent_features/_test_code_level_metrics.py

@@ -72,5 +72,5 @@ def __call__(self):
 TYPE_CONSTRUCTOR_CLASS_INSTANCE = ExerciseTypeConstructor()
 TYPE_CONSTRUCTOR_CALLABLE_CLASS_INSTANCE = ExerciseTypeConstructorCallable()
 
-exercise_lambda = lambda: None  # noqa: E731
+exercise_lambda = lambda: None
 exercise_partial = functools.partial(exercise_function)

tests/datastore_aredis/test_trace_node.py

@@ -80,26 +80,26 @@ async def _exercise_db():
 @override_application_settings(_enable_instance_settings)
 @validate_tt_collector_json(datastore_params=_enabled_required, datastore_forgone_params=_enabled_forgone)
 @background_task()
-def test_trace_node_datastore_params_enable_instance(loop):  # noqa: F811
+def test_trace_node_datastore_params_enable_instance(loop):
     loop.run_until_complete(_exercise_db())
 
 
 @override_application_settings(_disable_instance_settings)
 @validate_tt_collector_json(datastore_params=_disabled_required, datastore_forgone_params=_disabled_forgone)
 @background_task()
-def test_trace_node_datastore_params_disable_instance(loop):  # noqa: F811
+def test_trace_node_datastore_params_disable_instance(loop):
     loop.run_until_complete(_exercise_db())
 
 
 @override_application_settings(_instance_only_settings)
 @validate_tt_collector_json(datastore_params=_instance_only_required, datastore_forgone_params=_instance_only_forgone)
 @background_task()
-def test_trace_node_datastore_params_instance_only(loop):  # noqa: F811
+def test_trace_node_datastore_params_instance_only(loop):
     loop.run_until_complete(_exercise_db())
 
 
 @override_application_settings(_database_only_settings)
 @validate_tt_collector_json(datastore_params=_database_only_required, datastore_forgone_params=_database_only_forgone)
 @background_task()
-def test_trace_node_datastore_params_database_only(loop):  # noqa: F811
+def test_trace_node_datastore_params_database_only(loop):
     loop.run_until_complete(_exercise_db())

tests/datastore_elasticsearch/test_async_mget.py

@@ -15,7 +15,7 @@
 import pytest
 from conftest import ES_MULTIPLE_SETTINGS, ES_VERSION
 from elasticsearch import AsyncElasticsearch
-from testing_support.fixture.event_loop import event_loop as loop  # noqa: F401
+from testing_support.fixture.event_loop import event_loop as loop
 from testing_support.fixtures import override_application_settings
 from testing_support.util import instance_hostname
 from testing_support.validators.validate_transaction_metrics import validate_transaction_metrics

tests/datastore_elasticsearch/test_async_trace_node.py

@@ -13,7 +13,7 @@
 # limitations under the License.
 
 from conftest import ES_SETTINGS, ES_VERSION
-from testing_support.fixture.event_loop import event_loop as loop  # noqa: F401
+from testing_support.fixture.event_loop import event_loop as loop
 from testing_support.fixtures import override_application_settings, validate_tt_parenting
 from testing_support.util import instance_hostname
 from testing_support.validators.validate_tt_collector_json import validate_tt_collector_json

tests/external_aiobotocore/test_bedrock_chat_completion.py

@@ -33,7 +33,7 @@
     chat_completion_streaming_expected_events,
 )
 from testing_support.fixtures import override_llm_token_callback_settings, reset_core_stats_engine, validate_attributes
-from testing_support.ml_testing_utils import (  # noqa: F401
+from testing_support.ml_testing_utils import (
     add_token_count_to_events,
     disabled_ai_monitoring_record_content_settings,
     disabled_ai_monitoring_settings,

tests/external_aiobotocore/test_bedrock_embeddings.py

@@ -26,7 +26,7 @@
     embedding_payload_templates,
 )
 from testing_support.fixtures import override_llm_token_callback_settings, reset_core_stats_engine, validate_attributes
-from testing_support.ml_testing_utils import (  # noqa: F401
+from testing_support.ml_testing_utils import (
     add_token_count_to_events,
     disabled_ai_monitoring_record_content_settings,
     disabled_ai_monitoring_settings,

tests/framework_aiohttp/_target_application.py

@@ -29,7 +29,7 @@ async def index(request):
 
 async def hang(request):
     while True:  # noqa: ASYNC110
-        await asyncio.sleep(0)  # noqa: ASYNC110
+        await asyncio.sleep(0)
 
 
 async def error(request):

tests/messagebroker_kombu/conftest.py

@@ -21,7 +21,7 @@
 from amqp.exceptions import NotFound
 from kombu import messaging, serialization
 from testing_support.db_settings import rabbitmq_settings
-from testing_support.fixtures import collector_agent_registration_fixture, collector_available_fixture  # noqa: F401
+from testing_support.fixtures import collector_agent_registration_fixture, collector_available_fixture
 from testing_support.validators.validate_distributed_trace_accepted import validate_distributed_trace_accepted
 
 from newrelic.api.transaction import current_transaction

tests/mlmodel_gemini/conftest.py

@@ -53,7 +53,7 @@
 
 
 @pytest.fixture(scope="session")
-def gemini_clients(MockExternalGeminiServer):  # noqa: F811
+def gemini_clients(MockExternalGeminiServer):
     """
     This configures the Gemini client and returns it
     """
@@ -104,7 +104,7 @@ def gemini_server(gemini_clients, wrap_httpx_client_send):
 
 
 @pytest.fixture(scope="session")
-def wrap_httpx_client_send(extract_shortened_prompt):  # noqa: F811
+def wrap_httpx_client_send(extract_shortened_prompt):
     def _wrap_httpx_client_send(wrapped, instance, args, kwargs):
         bound_args = bind_args(wrapped, args, kwargs)
         request = bound_args["request"]