@@ -52,15 +52,9 @@ from fluxqueue import FluxQueue
5252fluxqueue = FluxQueue()
5353
5454@fluxqueue.task ()
55- def send_email (to_email : str , subject : str , body : str ):
55+ def send_email (to_email : str ):
5656 with email_context() as email_client:
57- message = EmailMessage()
58- message[" From" ] = " test@example.com"
59- message[" To" ] = to_email
60- message[" Subject" ] = subject
61- message.set_content(body)
62-
63- email_client.send_message(message)
57+ send_email(to_email, email_client)
6458```
6559
6660### Enqueue Tasks
@@ -79,15 +73,9 @@ FluxQueue supports async functions too. Just define an async function and use th
7973
8074``` python
8175@fluxqueue.task ()
82- async def send_email (to_email : str , subject : str , body : str ):
76+ async def send_email_task (to_email : str ):
8377 async with email_context() as email_client:
84- message = EmailMessage()
85- message[" From" ] = " test@example.com"
86- message[" To" ] = to_email
87- message[" Subject" ] = subject
88- message.set_content(body)
89-
90- await email_client.send_message(message)
78+ await send_email(to_email, email_client)
9179```
9280
9381Running the async function in an async context will also enqueue the task.
0 commit comments