24 lines
833 B
Python
24 lines
833 B
Python
import background.update
|
|
|
|
from background.broker import taskiq_broker
|
|
|
|
|
|
@taskiq_broker.task(task_name='process_update')
|
|
async def process_update(product_ids: list[int]):
|
|
return await background.update.process_update(product_ids)
|
|
|
|
|
|
@taskiq_broker.task(task_name='update_marketplace')
|
|
async def update_marketplace(marketplace_id: int):
|
|
return await background.update.update_marketplace(marketplace_id)
|
|
|
|
|
|
@taskiq_broker.task(task_name='update_marketplace_products')
|
|
async def update_marketplace_products(marketplace_id: int, product_ids: list[int]):
|
|
return await background.update.update_marketplace_products(marketplace_id, product_ids)
|
|
|
|
|
|
@taskiq_broker.task(task_name='update_marketplaces')
|
|
async def update_marketplaces(marketplace_ids: list[int]):
|
|
return await background.update.update_marketplaces(marketplace_ids)
|