CGM_Public/pretix_cgo
1
0
Fork 0
forked from CGM_Public/pretix_original
Code Pull Requests Actions Activity

Lock event during automatic waiting list assignment

Browse Source
This commit is contained in:
Raphael Michel
2017-10-24 12:47:08 +02:00
parent cb6f6247fd
commit 03dd0e530e
1 changed files with 26 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
src/pretix/base/services/waitinglist.py
View File

@@ -28,33 +28,34 @@ def assign_automatically(event_id: int, user_id: int=None, subevent_id: int=None
sent = 0 sent = 0
for wle in qs: with event.lock():
if (wle.item, wle.variation) in gone: for wle in qs:
continue if (wle.item, wle.variation) in gone:
quotas = (wle.variation.quotas.filter(subevent=wle.subevent)
if wle.variation
else wle.item.quotas.filter(subevent=wle.subevent))
availability = (
wle.variation.check_quotas(count_waitinglist=False, _cache=quota_cache, subevent=wle.subevent)
if wle.variation
else wle.item.check_quotas(count_waitinglist=False, _cache=quota_cache, subevent=wle.subevent)
)
if availability[1] > 0:
try:
wle.send_voucher(quota_cache, user=user)
sent += 1
except WaitingListException: # noqa
continue continue
# Reduce affected quotas in cache quotas = (wle.variation.quotas.filter(subevent=wle.subevent)
for q in quotas: if wle.variation
quota_cache[q.pk] = ( else wle.item.quotas.filter(subevent=wle.subevent))
quota_cache[q.pk][0] if quota_cache[q.pk][0] > 1 else 0, availability = (
quota_cache[q.pk][1] - 1 wle.variation.check_quotas(count_waitinglist=False, _cache=quota_cache, subevent=wle.subevent)
) if wle.variation
else: else wle.item.check_quotas(count_waitinglist=False, _cache=quota_cache, subevent=wle.subevent)
gone.add((wle.item, wle.variation)) )
if availability[1] > 0:
try:
wle.send_voucher(quota_cache, user=user)
sent += 1
except WaitingListException: # noqa
continue
# Reduce affected quotas in cache
for q in quotas:
quota_cache[q.pk] = (
quota_cache[q.pk][0] if quota_cache[q.pk][0] > 1 else 0,
quota_cache[q.pk][1] - 1
)
else:
gone.add((wle.item, wle.variation))
return sent return sent