Skip to content

Commit

Permalink
same as #7945 also for Publisher_rucio and a couple more places (#7946)
Browse files Browse the repository at this point in the history
  • Loading branch information
belforte authored Oct 13, 2023
1 parent 4c1a0da commit 3bc8e92
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions src/python/Publisher/PublisherMaster.py
Original file line number Diff line number Diff line change
Expand Up @@ -438,9 +438,9 @@ def algorithm(self):
maxSlaves = self.config.max_slaves
self.logger.info('kicking off pool for %s tasks using up to %s concurrent slaves', len(tasks), maxSlaves)
self.taskBlackList = os.listdir(self.blackListedTaskDir)
self.logger.debug('++++++ Using this taskBlackList: %s', self.taskBlackList)
self.logger.info('++++++ Using this taskBlackList: %s', self.taskBlackList)
# print one line per task with the number of files to be published. Allow to find stuck tasks
self.logger.debug(' # of acquired files : taskname')
self.logger.info(' # of acquired files : taskname')
for task in tasks:
taskName = task[0][3]
acquiredFiles = len(task[1])
Expand Down
6 changes: 3 additions & 3 deletions src/python/Publisher/PublisherMasterRucio.py
Original file line number Diff line number Diff line change
Expand Up @@ -363,14 +363,14 @@ def algorithm(self):
maxSlaves = self.config.max_slaves
self.logger.info('kicking off pool for %s tasks using up to %s concurrent slaves', len(tasks), maxSlaves)
self.taskBlackList = os.listdir(self.blackListedTaskDir)
self.logger.debug('++++++ Using this taskBlackList: %s', self.taskBlackList)
self.logger.info('++++++ Using this taskBlackList: %s', self.taskBlackList)
# print one line per task with the number of files to be published. Allow to find stuck tasks
self.logger.debug(' # of acquired files : taskname')
self.logger.info(' # of acquired files : taskname')
for task in tasks:
taskName = task['taskname']
acquiredFiles = len(task['fileDicts'])
flag = ' OK' if acquiredFiles < 1000 else 'WARN' # mark suspicious tasks
self.logger.debug('acquired_files: %s %5d : %s', flag, acquiredFiles, taskName)
self.logger.info('acquired_files: %s %5d : %s', flag, acquiredFiles, taskName)

processes = []
try: # pylint: disable=too-many-nested-blocks
Expand Down

0 comments on commit 3bc8e92

Please sign in to comment.