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

use upsert to avoid duplicate inserts

Browse source
This commit is contained in:
Mike McLean 2024-04-17 09:43:50 -04:00 • committed by Tomas Kopecek
parent d54dedc039
commit 1932796ef5
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
kojihub/kojihub.py
View file

@ -16116,11 +16116,13 @@ def create_rpm_checksum(rpm_id, sigkey, chsum_dict):
f"rpm ID {r['rpm_id']}, sigkey {r['sigkey']} and "
f"checksum type {koji.CHECKSUM_TYPES[r['checksum_type']]}.")
if chsum_dict:
insert = BulkInsertProcessor(table='rpm_checksum')
for func, chsum in sorted(chsum_dict.items()):
insert.add_record(rpm_id=rpm_id, sigkey=sigkey, checksum=chsum,
checksum_type=koji.CHECKSUM_TYPES[func])
insert.execute()
data = {'rpm_id': rpm_id,
'sigkey': sigkey,
'checksum': chsum,
'checksum_type': koji.CHECKSUM_TYPES[func]}
upsert = UpsertProcessor(table='rpm_checksum', data=data, skip_dup=True)
upsert.execute()
def reject_draft(data, is_rpm=False, error=None):