Revision 9e3af524 snf-astakos-app/astakos/im/functions.py
| b/snf-astakos-app/astakos/im/functions.py | ||
|---|---|---|
| 69 | 69 |
UserSetting, |
| 70 | 70 |
get_resource_names, new_chain) |
| 71 | 71 |
from astakos.im.quotas import (qh_sync_user, qh_sync_users, |
| 72 |
register_pending_apps, resolve_pending_serial)
|
|
| 72 |
register_pending_apps) |
|
| 73 | 73 |
from astakos.im.project_notif import ( |
| 74 | 74 |
membership_change_notify, membership_enroll_notify, |
| 75 | 75 |
membership_request_notify, membership_leave_request_notify, |
| ... | ... | |
| 78 | 78 |
project_termination_notify, project_suspension_notify) |
| 79 | 79 |
from astakos.im import settings |
| 80 | 80 |
import astakos.im.messages as astakos_messages |
| 81 |
from astakos.quotaholder_app.exception import NoCapacityError |
|
| 82 | 81 |
|
| 83 | 82 |
logger = logging.getLogger(__name__) |
| 84 | 83 |
|
| ... | ... | |
| 940 | 939 |
count = q.count() |
| 941 | 940 |
diff = 1 - count |
| 942 | 941 |
|
| 943 |
try: |
|
| 944 |
name = "DRYRUN" if dry_run else "" |
|
| 945 |
serial = register_pending_apps(user, diff, force, name=name) |
|
| 946 |
except NoCapacityError as e: |
|
| 947 |
limit = e.data['limit'] |
|
| 948 |
return False, limit |
|
| 949 |
else: |
|
| 950 |
accept = not dry_run |
|
| 951 |
resolve_pending_serial(serial, accept=accept) |
|
| 952 |
return True, None |
|
| 942 |
return register_pending_apps(user, diff, force, dry_run) |
|
| 953 | 943 |
|
| 954 | 944 |
|
| 955 | 945 |
def qh_release_pending_app(user): |
| 956 |
serial = register_pending_apps(user, -1) |
|
| 957 |
resolve_pending_serial(serial) |
|
| 946 |
register_pending_apps(user, -1) |
|
| 958 | 947 |
|
| 959 | 948 |
|
| 960 | 949 |
def qh_sync_projects(projects): |
Also available in: Unified diff