|
19 | 19 | import logging |
20 | 20 | import traceback |
21 | 21 |
|
22 | | -from app.api.helpers.files import create_save_image_sizes |
| 22 | +from app.api.helpers.files import create_save_image_sizes, create_save_resized_image |
23 | 23 | from app.api.helpers.request_context_task import RequestContextTask |
24 | 24 | from app.api.helpers.mail import send_export_mail, send_import_mail |
25 | 25 | from app.api.helpers.notification import send_notif_after_import, send_notif_after_export |
|
31 | 31 | from app.api.imports import import_event_task_base |
32 | 32 | from app.models.event import Event |
33 | 33 | from app.models.order import Order |
| 34 | +from app.models.sponsor import Sponsor |
34 | 35 | from app.models.discount_code import DiscountCode |
35 | 36 | from app.models.ticket_holder import TicketHolder |
36 | 37 | from app.api.helpers.ICalExporter import ICalExporter |
@@ -120,6 +121,20 @@ def resize_user_images_task(self, user_id, original_image_url): |
120 | 121 | logging.exception('Error encountered while generating resized images for user with id: {}'.format(user_id)) |
121 | 122 |
|
122 | 123 |
|
| 124 | +@celery.task(base=RequestContextTask, name='sponsor.logo.urls', bind=True) |
| 125 | +def sponsor_logos_url_task(self, event_id): |
| 126 | + sponsors = Sponsor.query.filter_by(event_id=event_id, deleted_at=None).all() |
| 127 | + for sponsor in sponsors: |
| 128 | + try: |
| 129 | + logging.info('Sponsor logo url generation task started {}'.format(sponsor.logo_url)) |
| 130 | + new_logo_url = create_save_resized_image(image_file=sponsor.logo_url, resize=False) |
| 131 | + sponsor.logo_url = new_logo_url |
| 132 | + save_to_db(sponsor) |
| 133 | + logging.info('Sponsor logo url successfully generated') |
| 134 | + except(urllib.error.HTTPError, urllib.error.URLError): |
| 135 | + logging.exception('Error encountered while logo generation') |
| 136 | + |
| 137 | + |
123 | 138 | @celery.task(base=RequestContextTask, name='resize.speaker.images', bind=True) |
124 | 139 | def resize_speaker_images_task(self, speaker_id, photo_url): |
125 | 140 | speaker = safe_query(db, Speaker, 'id', speaker_id, 'speaker_id') |
|
0 commit comments