Revision 5ce3ce4f snf-astakos-app/astakos/im/tasks.py
| b/snf-astakos-app/astakos/im/tasks.py | ||
|---|---|---|
| 38 | 38 |
|
| 39 | 39 |
from astakos.im.endpoints.quotaholder import send_quota |
| 40 | 40 |
from astakos.im.endpoints.aquarium.producer import (report_credits_event, |
| 41 |
report_user_event |
|
| 42 |
) |
|
| 41 |
report_user_event
|
|
| 42 |
)
|
|
| 43 | 43 |
from astakos.im.endpoints.aquarium.client import AquariumClient |
| 44 | 44 |
|
| 45 | 45 |
import logging |
| 46 | 46 |
|
| 47 | 47 |
logger = logging.getLogger(__name__) |
| 48 | 48 |
|
| 49 |
|
|
| 49 | 50 |
def log(func): |
| 50 | 51 |
@wraps(func) |
| 51 | 52 |
def wrapper(*args, **kwargs): |
| 52 | 53 |
logger.info('Starting the %s with args=%s kwargs=%s' % (
|
| 53 |
func, args, kwargs |
|
| 54 |
) |
|
| 55 |
) |
|
| 54 |
func, args, kwargs
|
|
| 55 |
)
|
|
| 56 |
)
|
|
| 56 | 57 |
return func(*args, **kwargs) |
| 57 | 58 |
return wrapper |
| 58 | 59 |
|
| 60 |
|
|
| 59 | 61 |
@periodic_task(run_every=crontab(day_of_month='1')) |
| 60 | 62 |
@log |
| 61 | 63 |
def propagate_credits_update(): |
| 62 | 64 |
report_credits_event() |
| 63 | 65 |
|
| 66 |
|
|
| 64 | 67 |
@task |
| 65 | 68 |
@log |
| 66 | 69 |
def propagate_groupmembers_quota(group): |
| ... | ... | |
| 68 | 71 |
return |
| 69 | 72 |
send_quota(group.approved_members) |
| 70 | 73 |
|
| 74 |
|
|
| 71 | 75 |
@task |
| 72 | 76 |
@log |
| 73 | 77 |
def request_billing(user, start, end): |
Also available in: Unified diff