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

10 statements  

« prev     ^ index     » next       coverage.py v7.10.6, created at 2025-12-05 16:17 +0000

1from typing import Unpack 1a

2 

3from polar.worker import TaskPriority, actor 1a

4 

5from .client import Properties 1a

6from .client import client as loops_client 1a

7 

8 

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

10async def loops_update_contact( 1a

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) 1a

17async def loops_send_event( 1a

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

19) -> None: 

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