Coverage for polar/integrations/loops/tasks.py: 80%

1from typing import Unpack 

2 

3from polar.worker import TaskPriority, actor 

4 

5from .client import Properties 

6from .client import client as loops_client 

7 

8 

9@actor(actor_name="loops.update_contact", priority=TaskPriority.LOW) 

10async def loops_update_contact( 

11 email: str, id: str, **properties: Unpack[Properties] 

12) -> None: 

13 await loops_client.update_contact(email, id, **properties) 

14 

15 

16@actor(actor_name="loops.send_event", priority=TaskPriority.LOW) 

17async def loops_send_event( 

18 email: str, event_name: str, **properties: Unpack[Properties] 

19) -> None: 

20 await loops_client.send_event(email, event_name, **properties)