Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/DIRAC/Core/DISET/ThreadConfig.py
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ def wrapper(*args, **kwargs):

:return: wrapped method
"""
deco = tc.getDecorator()
deco = tc.getDecorator() # pylint: disable=no-member
if not deco:
return method(*args, **kwargs)
# Deco is a decorator sooo....
Expand Down
13 changes: 8 additions & 5 deletions src/DIRAC/Core/DISET/private/BaseClient.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
""" This module exposes the BaseClient class,
which serves as base for InnerRPCClient and TransferClient.
"""This module exposes the BaseClient class,
which serves as base for InnerRPCClient and TransferClient.
"""

import time

import _thread
Expand Down Expand Up @@ -130,7 +131,7 @@ def __discoverSetup(self):
if self.KW_SETUP in self.kwargs and self.kwargs[self.KW_SETUP]:
self.setup = str(self.kwargs[self.KW_SETUP])
else:
self.setup = self.__threadConfig.getSetup()
self.setup = self.__threadConfig.getSetup() # pylint: disable=no-member
if not self.setup:
self.setup = gConfig.getValue("/DIRAC/Setup", "Test")
return S_OK()
Expand Down Expand Up @@ -258,8 +259,10 @@ def __discoverExtraCredentials(self):
self.__extraCredentials = self.kwargs[self.KW_EXTRA_CREDENTIALS]

# Are we delegating something?
delegatedDN = self.kwargs.get(self.KW_DELEGATED_DN) or self.__threadConfig.getDN()
delegatedGroup = self.kwargs.get(self.KW_DELEGATED_GROUP) or self.__threadConfig.getGroup()
delegatedDN = self.kwargs.get(self.KW_DELEGATED_DN) or self.__threadConfig.getDN() # pylint: disable=no-member
delegatedGroup = (
self.kwargs.get(self.KW_DELEGATED_GROUP) or self.__threadConfig.getGroup() # pylint: disable=no-member
)
if delegatedDN:
self.kwargs[self.KW_DELEGATED_DN] = delegatedDN
if not delegatedGroup:
Expand Down
4 changes: 2 additions & 2 deletions src/DIRAC/Core/Tornado/Client/private/TornadoBaseClient.py
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,7 @@ def __discoverSetup(self):
if self.KW_SETUP in self.kwargs and self.kwargs[self.KW_SETUP]:
self.setup = str(self.kwargs[self.KW_SETUP])
else:
self.setup = self.__threadConfig.getSetup()
self.setup = self.__threadConfig.getSetup() # pylint: disable=no-member
if not self.setup:
self.setup = gConfig.getValue("/DIRAC/Setup", "Test")
return S_OK()
Expand Down Expand Up @@ -284,7 +284,7 @@ def __discoverExtraCredentials(self):
if self.KW_EXTRA_CREDENTIALS in self.kwargs:
self.__extraCredentials = self.kwargs[self.KW_EXTRA_CREDENTIALS]
# Are we delegating something?
delegatedDN, delegatedGroup = self.__threadConfig.getID()
delegatedDN, delegatedGroup = self.__threadConfig.getID() # pylint: disable=no-member
if self.KW_DELEGATED_DN in self.kwargs and self.kwargs[self.KW_DELEGATED_DN]:
delegatedDN = self.kwargs[self.KW_DELEGATED_DN]
elif delegatedDN:
Expand Down
4 changes: 2 additions & 2 deletions src/DIRAC/DataManagementSystem/Service/S3GatewayHandler.py
Original file line number Diff line number Diff line change
Expand Up @@ -116,8 +116,8 @@ def export_createPresignedUrl(self, storageName, s3_method, urls, expiration):
# If we can't obtain remote credentials, consider it permission denied
return S_ERROR(errno.EACCES, "Could not obtain remote credentials")

self._tc.setDN(credDict["DN"])
self._tc.setGroup(credDict["group"])
self._tc.setDN(credDict["DN"]) # pylint: disable=no-member
self._tc.setGroup(credDict["group"]) # pylint: disable=no-member

successful = {}
failed = {}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -397,7 +397,7 @@ def create_authorization_response(self, response, username):
"""
try:
response = super().create_authorization_response(response, username)
response.clear_cookie("auth_session")
response.clear_cookie("auth_session") # pylint: disable=no-member
return response
except Exception as e:
sLog.exception(e)
Expand Down
4 changes: 2 additions & 2 deletions src/DIRAC/Resources/Catalog/ConditionPlugins/ProxyPlugin.py
Original file line number Diff line number Diff line change
Expand Up @@ -60,8 +60,8 @@ def __init__(self, conditions):
# We may not have a proxy, check the thread local
if not self.proxyInfo:
tc = ThreadConfig()
userDN = tc.getDN()
userGroup = tc.getGroup()
userDN = tc.getDN() # pylint: disable=no-member
userGroup = tc.getGroup() # pylint: disable=no-member
if userDN and userGroup:
userName = Registry.getUsernameForDN(userDN).get("Value")
if userName:
Expand Down
4 changes: 2 additions & 2 deletions src/DIRAC/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@
import sys
import warnings
from pkgutil import extend_path
from typing import Any, Optional, Union
from typing import Any, NoReturn, Optional, Union


__path__ = extend_path(__path__, __name__)
Expand Down Expand Up @@ -298,7 +298,7 @@ def siteName():
from DIRAC.Core.Utilities.Platform import getPlatformString, getPlatform, getPlatformTuple


def exit(exitCode=0):
def exit(exitCode=0) -> NoReturn:
"""
Finish execution using callbacks
"""
Expand Down
Loading