Coverage for polar/billing_entry/tasks.py: 62%

8 statements  

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

1import uuid 1a

2 

3from polar.worker import AsyncSessionMaker, TaskPriority, actor 1a

4 

5from .repository import BillingEntryRepository 1a

6 

7 

8@actor(actor_name="billing_entry.set_order_item", priority=TaskPriority.LOW) 1a

9async def set_order_item( 1a

10 billing_entries: list[uuid.UUID], order_item_id: uuid.UUID 

11) -> None: 

12 async with AsyncSessionMaker() as session: 

13 repository = BillingEntryRepository.from_session(session) 

14 await repository.update_order_item_id(billing_entries, order_item_id)