[core] declaring "global" var access is useless

This commit is contained in:
Fabien Castan 2025-04-14 10:50:57 +02:00
parent b9a5c00279
commit 2ad55352ee
2 changed files with 1 additions and 8 deletions

View file

@ -310,7 +310,6 @@ def registerNodeType(nodeType):
After registration, nodes of this type can be instantiated in a Graph.
"""
global nodesDesc
if nodeType.__name__ in nodesDesc:
logging.error(f"Node Desc {nodeType.__name__} is already registered.")
nodesDesc[nodeType.__name__] = nodeType
@ -318,7 +317,6 @@ def registerNodeType(nodeType):
def unregisterNodeType(nodeType):
""" Remove 'nodeType' from the list of register node types. """
global nodesDesc
assert nodeType.__name__ in nodesDesc
del nodesDesc[nodeType.__name__]
@ -332,7 +330,6 @@ def loadNodes(folder, packageName):
def loadAllNodes(folder):
global nodesDesc
for importer, package, ispkg in pkgutil.walk_packages([folder]):
if ispkg:
nodeTypes = loadNodes(folder, package)
@ -372,7 +369,6 @@ def loadPluginsFolder(folder):
def registerSubmitter(s):
global submitters
if s.name in submitters:
logging.error(f"Submitter {s.name} is already registered.")
submitters[s.name] = s
@ -387,7 +383,6 @@ def loadSubmitters(folder, packageName):
def loadPipelineTemplates(folder):
global pipelineTemplates
if not os.path.isdir(folder):
logging.error(f"Pipeline templates folder '{folder}' does not exist.")
return

View file

@ -298,12 +298,11 @@ class LogManager:
return logging.NOTSET
runningProcesses = {}
runningProcesses: dict[str, "NodeChunk"] = {}
@atexit.register
def clearProcessesStatus():
global runningProcesses
for k, v in runningProcesses.items():
v.upgradeStatusTo(Status.KILLED)
@ -474,7 +473,6 @@ class NodeChunk(BaseObject):
self._processInIsolatedEnvironment()
return
global runningProcesses
runningProcesses[self.name] = self
self._status.setNode(self.node)
self._status.initStartCompute()