jan/punkow
1
0
Fork 0
mirror of https://github.com/janLo/punkow synced 2026-06-19 15:38:00 +00:00
Code Issues Releases Wiki Activity

Do not block in mailer

Browse Source
This commit is contained in:
Jan Losinski
2019-01-21 22:14:13 +01:00
parent cc5412a3bd
commit 67fb250963
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
punkow/service/mailer.py
+2 -2
View File
@@ -76,7 +76,7 @@ class Mailer(object):
async def send_success_email(self, email, booking: scraper.BookingResult): async def send_success_email(self, email, booking: scraper.BookingResult):
tpl = self._tpl.get_template("success.txt") tpl = self._tpl.get_template("success.txt")
text = tpl.render(meta=booking.metadata, change_url=scraper.MANAGE_URL, text = tpl.render(meta=booking.metadata, change_url=scraper.BASE_URL + scraper.MANAGE_URL,
process_id=booking.process_id, auth_code=booking.auth_key) process_id=booking.process_id, auth_code=booking.auth_key)
await self._send_email(email, "Your appointment was booked", text) await self._send_email(email, "Your appointment was booked", text)
@@ -109,7 +109,7 @@ class AsyncMailQueue(object):
async def __aexit__(self, exc_type, exc_val, exc_tb): async def __aexit__(self, exc_type, exc_val, exc_tb):
if len(self._queue) != 0: if len(self._queue) != 0:
await self._loop.run_in_executor(None, functools.partial( await self._loop.run_in_executor(None, functools.partial(
concurrent.futures.wait(self._queue))) concurrent.futures.wait, self._queue))
def _append_task(self, coro): def _append_task(self, coro):
self._queue.append(asyncio.run_coroutine_threadsafe(coro, self._loop)) self._queue.append(asyncio.run_coroutine_threadsafe(coro, self._loop))