diff --git a/lib/rucio/common/plugins.py b/lib/rucio/common/plugins.py index e3a5c54146..a0a804da07 100644 --- a/lib/rucio/common/plugins.py +++ b/lib/rucio/common/plugins.py @@ -23,7 +23,7 @@ PolicyPackageAlgorithmsT = TypeVar('PolicyPackageAlgorithmsT', bound='PolicyPackageAlgorithms') -class PolicyPackageAlgorithms(): +class PolicyPackageAlgorithms: """ Base class for Rucio Policy Package Algorithms diff --git a/lib/rucio/core/rse_selector.py b/lib/rucio/core/rse_selector.py index 7c320e90d7..a1e98446d6 100644 --- a/lib/rucio/core/rse_selector.py +++ b/lib/rucio/core/rse_selector.py @@ -27,7 +27,7 @@ from sqlalchemy.orm import Session -class RSESelector(): +class RSESelector: """ Representation of the RSE selector """ diff --git a/lib/rucio/daemons/c3po/collectors/jedi_did.py b/lib/rucio/daemons/c3po/collectors/jedi_did.py index cf1a861d2c..51a4fbfd97 100644 --- a/lib/rucio/daemons/c3po/collectors/jedi_did.py +++ b/lib/rucio/daemons/c3po/collectors/jedi_did.py @@ -17,7 +17,7 @@ from rucio.db.sqla.session import read_session -class JediDIDCollector(): +class JediDIDCollector: def __init__(self, queue): self.queue = queue self.max_tid = 0 diff --git a/tests/test_abacus_account.py b/tests/test_abacus_account.py index 3d2cebcca2..7569f26993 100644 --- a/tests/test_abacus_account.py +++ b/tests/test_abacus_account.py @@ -26,7 +26,7 @@ @pytest.mark.noparallel(reason='uses daemon, failing in parallel to other tests, updates account') -class TestAbacusAccount2(): +class TestAbacusAccount2: def test_abacus_account(self, vo, root_account, mock_scope, rse_factory, did_factory, rucio_client): """ ABACUS (ACCOUNT): Test update of account usage """ diff --git a/tests/test_abacus_collection_replica.py b/tests/test_abacus_collection_replica.py index 7e60984c9a..e117f1dd56 100644 --- a/tests/test_abacus_collection_replica.py +++ b/tests/test_abacus_collection_replica.py @@ -28,7 +28,7 @@ @pytest.mark.noparallel(reason='uses daemons, fails when run in parallel') -class TestAbacusCollectionReplica(): +class TestAbacusCollectionReplica: def test_abacus_collection_replica_cleanup(self, vo, mock_scope, rse_factory, did_client, jdoe_account): """ ABACUS (COLLECTION REPLICA): Test if the cleanup procedure works correctly. """ diff --git a/tests/test_abacus_rse.py b/tests/test_abacus_rse.py index 0836db2730..b5a63f0194 100644 --- a/tests/test_abacus_rse.py +++ b/tests/test_abacus_rse.py @@ -23,7 +23,7 @@ @pytest.mark.noparallel(reason='uses daemon, failing in parallel to other tests') -class TestAbacusRSE(): +class TestAbacusRSE: def test_abacus_rse(self, vo, mock_scope, rse_factory, did_factory, rucio_client): """ ABACUS (RSE): Test update of RSE usage. """ diff --git a/tests/test_auditor.py b/tests/test_auditor.py index 9c751a5721..4bd7b05644 100644 --- a/tests/test_auditor.py +++ b/tests/test_auditor.py @@ -106,7 +106,7 @@ def test_auditor_check_survives_failures_and_queues_failed_rses(mock_auditor): lambda: None, ) - class MockMultiProcessing(): + class MockMultiProcessing: def is_set(self): return queue.empty() terminate = MockMultiProcessing() diff --git a/tests/test_module_import.py b/tests/test_module_import.py index c78d1d722e..8094f636fd 100644 --- a/tests/test_module_import.py +++ b/tests/test_module_import.py @@ -15,7 +15,7 @@ from rucio.common.utils import execute -class TestModuleImport(): +class TestModuleImport: def test_import(self): """ """ cmd = 'rucio --version' diff --git a/tools/monitoring/extract.py b/tools/monitoring/extract.py index 3de2ad8aaa..2cfdefec0e 100644 --- a/tools/monitoring/extract.py +++ b/tools/monitoring/extract.py @@ -28,7 +28,7 @@ import stomp -class ElasticConn(): +class ElasticConn: def __init__(self, host_port, auth): self.__es = es.Elasticsearch([host_port[0]],http_auth=auth,consumer_port=host_port[1])