particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

PR#3566: Fix koji-sweep-db

Browse source 
Merges #3566
https://pagure.io/koji/pull-request/3566

Fixes: #3466
https://pagure.io/koji/issue/3466
Move Query/Update/Insert/..../Processors from kojihub.py to koji/db.py
This commit is contained in:
Tomas Kopecek 2022-11-02 13:35:59 +01:00
commit 99506e4c2c
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
util/koji-sweep-db
View file

@ -74,7 +74,8 @@ def clean_scratch_tasks(cursor, vacuum, test, age):
cursor.execute("CREATE TEMPORARY TABLE temp_scratch_tasks (task_id INTEGER NOT NULL)")
query = QueryProcessor(tables=['task'], columns=['id', 'request'], clauses=clauses)
for row in query.execute():
task_id, request = row
task_id = row['id']
request = row['request']
try:
params, _ = xmlrpc.client.loads(request)
opts = params[2]
@ -97,7 +98,7 @@ def clean_scratch_tasks(cursor, vacuum, test, age):
clauses=["parent IN %(parents)s"],
values={'parents': parents})
for row in query.execute():
children.append(row[0])
children.append(row['id'])
parents = children
if children:
insert = BulkInsertProcessor(table='temp_scratch_tasks')