Replace flake8 and isort with Ruff

.github/workflows/changelog-label-check.py

@@ -1,6 +1,6 @@
 import json
 import os
-import re
+import re  # noqa: F401
 
 
 with open(os.environ['GITHUB_EVENT_PATH']) as event_file:

.gitlab/reminder/remind.py

@@ -1,7 +1,7 @@
 # (C) Datadog, Inc. 2019-present
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
-import json
+import json  # noqa: F401
 import os
 import sys
 import time

.gitlab/validate-logs-intgs/validate_log_intgs.py

@@ -2,7 +2,7 @@
 This script is expected to run from a CLI, do not import it."""
 import sys
 import json
-from typing import List, Optional, Set
+from typing import List, Optional, Set  # noqa: F401
 import re
 import yaml
 import os

.stubs/pyVmomi/vim/__init__.pyi

@@ -2,9 +2,9 @@ from datetime import datetime
 from enum import Enum
 from typing import Any, List
 
-from . import event
-from . import fault
-from . import view
+from . import event  # noqa: F401
+from . import fault  # noqa: F401
+from . import view  # noqa: F401
 from ..vmodl.query import PropertyCollector
 from .event import EventManager
 from .option import OptionManager

.stubs/pyVmomi/vim/option.pyi

@@ -1,6 +1,6 @@
-from typing import Any, List, Type
+from typing import Any, List, Type  # noqa: F401
 
-from pyVmomi.vim import ManagedEntity
+from pyVmomi.vim import ManagedEntity  # noqa: F401
 
 class OptionManager:
     def QueryOptions(self, name: str) -> List[OptionValue]: ...

.stubs/pyVmomi/vmodl/__init__.pyi

@@ -1,7 +1,7 @@
 from typing import Any
 
-from . import fault
-from . import query
+from . import fault  # noqa: F401
+from . import query  # noqa: F401
 
 class DynamicProperty:
     name: str

active_directory/tests/test_active_directory.py

@@ -6,7 +6,7 @@
 
 from datadog_checks.active_directory import ActiveDirectoryCheck
 from datadog_checks.active_directory.metrics import DEFAULT_COUNTERS
-from datadog_checks.base.stubs.aggregator import AggregatorStub
+from datadog_checks.base.stubs.aggregator import AggregatorStub  # noqa: F401
 from datadog_checks.dev.testing import requires_py2
 from datadog_checks.dev.utils import get_metadata_metrics
 

aerospike/datadog_checks/aerospike/aerospike.py

@@ -8,7 +8,7 @@
 
 import re
 from collections import defaultdict
-from typing import List
+from typing import List  # noqa: F401
 
 from six import PY2, iteritems
 

azure_iot_edge/datadog_checks/azure_iot_edge/config.py

@@ -1,13 +1,13 @@
 # (C) Datadog, Inc. 2020-present
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
-from typing import List
+from typing import List  # noqa: F401
 
 from datadog_checks.base import ConfigurationError
-from datadog_checks.base.types import InstanceType
+from datadog_checks.base.types import InstanceType  # noqa: F401
 
 from .metrics import EDGE_AGENT_METRICS, EDGE_AGENT_TYPE_OVERRIDES, EDGE_HUB_METRICS
-from .types import Instance
+from .types import Instance  # noqa: F401
 
 
 class Config(object):

azure_iot_edge/datadog_checks/azure_iot_edge/metrics.py

@@ -16,7 +16,6 @@
         'edgehub_reported_properties_update_duration_seconds': 'reported_properties_update_duration_seconds',
         'edgehub_direct_method_duration_seconds': 'direct_method_duration_seconds',
         'edgehub_direct_methods_total': 'direct_methods_total',
-        'edgehub_queue_length': 'queue_length',
         'edgehub_messages_dropped_total': 'messages_dropped_total',
         'edgehub_messages_unack_total': 'messages_unack_total',
         'edgehub_offline_count_total': 'offline_count_total',

azure_iot_edge/tests/common.py

@@ -2,7 +2,7 @@
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
 import os
-from typing import List, Tuple
+from typing import List, Tuple  # noqa: F401
 
 from datadog_checks.base import is_affirmative
 from datadog_checks.base.stubs.aggregator import AggregatorStub

azure_iot_edge/tests/conftest.py

@@ -5,7 +5,7 @@
 
 import pytest
 
-from datadog_checks.azure_iot_edge.types import Instance
+from datadog_checks.azure_iot_edge.types import Instance  # noqa: F401
 from datadog_checks.dev import docker_run
 from datadog_checks.dev.conditions import CheckDockerLogs, WaitFor
 

azure_iot_edge/tests/e2e_utils.py

@@ -1,7 +1,7 @@
 # (C) Datadog, Inc. 2020-present
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
-from typing import Any
+from typing import Any  # noqa: F401
 
 import requests
 

azure_iot_edge/tests/test_check.py

@@ -2,15 +2,15 @@
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
 import copy
-from typing import Callable
+from typing import Callable  # noqa: F401
 
 import pytest
 import requests
 
 from datadog_checks.azure_iot_edge import AzureIoTEdgeCheck
-from datadog_checks.azure_iot_edge.types import Instance
-from datadog_checks.base.stubs.aggregator import AggregatorStub
-from datadog_checks.base.stubs.datadog_agent import DatadogAgentStub
+from datadog_checks.azure_iot_edge.types import Instance  # noqa: F401
+from datadog_checks.base.stubs.aggregator import AggregatorStub  # noqa: F401
+from datadog_checks.base.stubs.datadog_agent import DatadogAgentStub  # noqa: F401
 from datadog_checks.dev.utils import get_metadata_metrics
 
 from . import common

azure_iot_edge/tests/test_config.py

@@ -5,7 +5,7 @@
 
 from datadog_checks.azure_iot_edge.config import Config
 from datadog_checks.azure_iot_edge.metrics import EDGE_AGENT_METRICS, EDGE_AGENT_TYPE_OVERRIDES, EDGE_HUB_METRICS
-from datadog_checks.azure_iot_edge.types import Instance
+from datadog_checks.azure_iot_edge.types import Instance  # noqa: F401
 from datadog_checks.base import ConfigurationError
 
 

azure_iot_edge/tests/test_e2e.py

@@ -2,13 +2,13 @@
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
 import copy
-from typing import Callable
+from typing import Callable  # noqa: F401
 
 import pytest
 import requests
 
 from datadog_checks.azure_iot_edge import AzureIoTEdgeCheck
-from datadog_checks.base.stubs.aggregator import AggregatorStub
+from datadog_checks.base.stubs.aggregator import AggregatorStub  # noqa: F401
 
 from . import common
 

cacti/datadog_checks/cacti/cacti.py

@@ -137,7 +137,7 @@ def _read_rrd(self, rrd_path, hostname, device_name, tags):
             return metric_count
 
         # Find the consolidation functions for the RRD metrics
-        c_funcs = set([v for k, v in info.items() if k.endswith('.cf')])
+        c_funcs = {v for k, v in info.items() if k.endswith('.cf')}
         if not c_funcs:
             self.log.debug("No funcs found for %s", rrd_path)
 
@@ -223,7 +223,7 @@ def _in_whitelist(rrd):
                 res.append((hostname, device_name, rrd_path))
 
         # Collect stats
-        num_hosts = len(set([r[0] for r in res]))
+        num_hosts = len({r[0] for r in res})
         self.gauge('cacti.rrd.count', len(res), tags=tags)
         self.gauge('cacti.hosts.count', num_hosts, tags=tags)
 

citrix_hypervisor/datadog_checks/citrix_hypervisor/check.py

@@ -1,7 +1,7 @@
 # (C) Datadog, Inc. 2021-present
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
-from typing import Any, Dict, List
+from typing import Any, Dict, List  # noqa: F401
 
 import yaml
 from six.moves import xmlrpc_client as xmlrpclib

citrix_hypervisor/datadog_checks/citrix_hypervisor/metrics.py

@@ -2,7 +2,7 @@
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
 import re
-from typing import Any, List, Optional, Tuple
+from typing import Any, List, Optional, Tuple  # noqa: F401
 
 SIMPLE_METRICS = {
     'memory': '.memory',

cloud_foundry_api/datadog_checks/cloud_foundry_api/cloud_foundry_api.py

@@ -4,15 +4,15 @@
 import copy
 import json
 import time
-from typing import Any, Dict, Generator, Tuple
+from typing import Any, Dict, Generator, Tuple  # noqa: F401
 
 from requests.exceptions import HTTPError, RequestException
 from semver import VersionInfo
 from six.moves.urllib_parse import urlparse
 
 from datadog_checks.base import AgentCheck
 from datadog_checks.base.errors import CheckException, ConfigurationError
-from datadog_checks.base.types import Event
+from datadog_checks.base.types import Event  # noqa: F401
 
 from .constants import (
     API_SERVICE_CHECK_NAME,

cloud_foundry_api/datadog_checks/cloud_foundry_api/utils.py

@@ -2,7 +2,7 @@
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
 from datetime import datetime
-from typing import Any, Dict
+from typing import Any, Dict  # noqa: F401
 
 from dateutil import parser, tz
 from six.moves.urllib_parse import urljoin

cloudera/tests/test_integration.py

@@ -5,10 +5,10 @@
 from contextlib import nullcontext as does_not_raise
 
 import pytest
-from tests.common import METRICS
 
 from datadog_checks.base.types import ServiceCheck
 from datadog_checks.cloudera.metrics import TIMESERIES_METRICS
+from tests.common import METRICS
 
 
 @pytest.mark.usefixtures('dd_environment')

cloudera/tests/test_unit_autodiscover.py

@@ -9,10 +9,10 @@
 import mock
 import pytest
 from packaging.version import Version
-from tests.common import query_time_series
 
 from datadog_checks.base.types import ServiceCheck
 from datadog_checks.cloudera.metrics import NATIVE_METRICS, TIMESERIES_METRICS
+from tests.common import query_time_series
 
 pytestmark = [pytest.mark.unit]
 

cloudera/tests/test_unit_clusters.py

@@ -5,10 +5,10 @@
 import mock
 import pytest
 from packaging.version import Version
-from tests.common import query_time_series
 
 from datadog_checks.base.types import ServiceCheck
 from datadog_checks.cloudera.metrics import TIMESERIES_METRICS
+from tests.common import query_time_series
 
 pytestmark = [pytest.mark.unit]
 

cloudera/tests/test_unit_disks.py

@@ -8,10 +8,10 @@
 import mock
 import pytest
 from packaging.version import Version
-from tests.common import query_time_series
 
 from datadog_checks.base.types import ServiceCheck
 from datadog_checks.cloudera.metrics import TIMESERIES_METRICS
+from tests.common import query_time_series
 
 pytestmark = [pytest.mark.unit]
 

cloudera/tests/test_unit_hosts.py

@@ -8,10 +8,10 @@
 import mock
 import pytest
 from packaging.version import Version
-from tests.common import query_time_series
 
 from datadog_checks.base.types import ServiceCheck
 from datadog_checks.cloudera.metrics import NATIVE_METRICS, TIMESERIES_METRICS
+from tests.common import query_time_series
 
 pytestmark = [pytest.mark.unit]
 

cloudera/tests/test_unit_roles.py

@@ -8,10 +8,10 @@
 import mock
 import pytest
 from packaging.version import Version
-from tests.common import query_time_series
 
 from datadog_checks.base.types import ServiceCheck
 from datadog_checks.cloudera.metrics import TIMESERIES_METRICS
+from tests.common import query_time_series
 
 pytestmark = [pytest.mark.unit]
 

confluent_platform/tests/test_e2e.py

@@ -1,11 +1,11 @@
 # (C) Datadog, Inc. 2020-present
 # All rights reserved
 # Licensed under a 3-clause BSD style license (see LICENSE)
-from typing import Any
+from typing import Any  # noqa: F401
 
 import pytest
 
-from datadog_checks.base.stubs.aggregator import AggregatorStub
+from datadog_checks.base.stubs.aggregator import AggregatorStub  # noqa: F401
 
 from .common import CHECK_CONFIG
 from .conftest import CONFLUENT_VERSION

consul/tests/test_unit.py

@@ -518,14 +518,14 @@ def test_config(test_case, extra_config, expected_http_kwargs, mocker):
 
         check.check(None)
 
-        http_wargs = dict(
-            auth=mock.ANY,
-            cert=mock.ANY,
-            headers=mock.ANY,
-            proxies=mock.ANY,
-            timeout=mock.ANY,
-            verify=mock.ANY,
-            allow_redirects=mock.ANY,
-        )
+        http_wargs = {
+            'auth': mock.ANY,
+            'cert': mock.ANY,
+            'headers': mock.ANY,
+            'proxies': mock.ANY,
+            'timeout': mock.ANY,
+            'verify': mock.ANY,
+            'allow_redirects': mock.ANY,
+        }
         http_wargs.update(expected_http_kwargs)
         r.get.assert_called_with('/v1/status/leader', **http_wargs)

couch/tests/test_couchv2.py

@@ -358,7 +358,7 @@ def run(self):
                     self.compact_views()
                 theid = ''.join(random.choice(string.ascii_uppercase + string.digits) for _ in range(10))
                 docs.append(self.post_doc(theid))
-                docs = list(map(lambda x: self.update_doc(x), docs))
+                docs = [self.update_doc(x) for x in docs]
                 self.generate_views()
 
         def generate_views(self):

couch/tests/test_unit.py

@@ -33,15 +33,15 @@ def test_config(test_case, extra_config, expected_http_kwargs):
 
         check.check(instance)
 
-        http_wargs = dict(
-            auth=mock.ANY,
-            cert=mock.ANY,
-            headers=mock.ANY,
-            proxies=mock.ANY,
-            timeout=mock.ANY,
-            verify=mock.ANY,
-            allow_redirects=mock.ANY,
-        )
+        http_wargs = {
+            'auth': mock.ANY,
+            'cert': mock.ANY,
+            'headers': mock.ANY,
+            'proxies': mock.ANY,
+            'timeout': mock.ANY,
+            'verify': mock.ANY,
+            'allow_redirects': mock.ANY,
+        }
         http_wargs.update(expected_http_kwargs)
 
         r.get.assert_called_with('http://{}:5984/_all_dbs/'.format(common.HOST), **http_wargs)