From 6169e6ba5d7fcff80eeb1dfe816932990b229455 Mon Sep 17 00:00:00 2001 From: yuyiguo Date: Fri, 21 Apr 2023 09:13:12 -0500 Subject: [PATCH] comment out the resubmission temporarily --- lib/rucio/daemons/tracer/kronos.py | 25 +++++++++++++------------ 1 file changed, 13 insertions(+), 12 deletions(-) diff --git a/lib/rucio/daemons/tracer/kronos.py b/lib/rucio/daemons/tracer/kronos.py index d27ebc4ec2..1ee40109e5 100644 --- a/lib/rucio/daemons/tracer/kronos.py +++ b/lib/rucio/daemons/tracer/kronos.py @@ -274,18 +274,19 @@ def __update_atime(self): for replica in replicas: # if touch replica hits a locked row put the trace back into queue for later retry if not touch_replica(replica): - resubmit = {'filename': replica['name'], - 'scope': replica['scope'].external, - 'remoteSite': replica['rse'], - 'traceTimeentryUnix': replica['traceTimeentryUnix'], - 'eventType': 'get', - 'usrdn': 'someuser', - 'clientState': 'DONE', - 'eventVersion': replica['eventVersion']} - if replica['scope'].vo != 'def': - resubmit['vo'] = replica['scope'].vo - self.__conn.send(body=jdumps(resubmit), destination=self.__queue, headers={'appversion': 'rucio', 'resubmitted': '1'}) - METRICS.counter('sent_resubmitted').inc() + #resubmit = {'filename': replica['name'], + # 'scope': replica['scope'].external, + # 'remoteSite': replica['rse'], + # 'traceTimeentryUnix': replica['traceTimeentryUnix'], + # 'eventType': 'get', + # 'usrdn': 'someuser', + # 'clientState': 'DONE', + # 'eventVersion': replica['eventVersion']} + #if replica['scope'].vo != 'def': + # resubmit['vo'] = replica['scope'].vo + #self.__conn.send(body=jdumps(resubmit), destination=self.__queue, headers={'appversion': 'rucio', 'resubmitted': '1'}) + #METRICS.counter('sent_resubmitted').inc() + pass METRICS.timer('update_atime').observe(stopwatch.elapsed) except Exception: self.__logger(logging.ERROR, "Cannot update replicas.", exc_info=True)