cco/loops-ext
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

cco.processor: fix handling of messages returned by create and update actions

Browse source
This commit is contained in:
Helmut Merz 2025-02-26 19:13:16 +01:00
parent f8480b0b4a
commit 3ac1a6c512
1 changed files with 19 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
cco/processor/controller.py
View file

@ -18,9 +18,10 @@ def loop(jobname, fct, data, skip=0, limit=None,
break break
for row in data: for row in data:
r = fct(row) r = fct(row)
result['count'] += 1 #result['count'] += 1
if r is not None: #if r is not None:
result[r] += 1 # result[r['info']] += 1
update_counters(result, r)
if result['count'] % bsize == 0: if result['count'] % bsize == 0:
logger.info('loop %s: %s' % (jobname, result)) logger.info('loop %s: %s' % (jobname, result))
if action is not None: if action is not None:
@ -31,3 +32,18 @@ def loop(jobname, fct, data, skip=0, limit=None,
action() action()
logger.info('loop %s finished: %s' % (jobname, result)) logger.info('loop %s finished: %s' % (jobname, result))
return result return result
def update_counters(result, msg):
result['count'] += 1
if msg is None:
return
if isinstance(msg, dict):
info = msg.get('info')
if info == 'error':
result['error'] += 1
return
key = msg['action'] + 'd'
if key in result:
result[key] += 1
else:
result[msg] += 1