18 lines
543 B
Python
18 lines
543 B
Python
"""CV-upload Taskiq tasks — same matcher as inbox.tasks, own broker/stream."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from inbox.tasks import match_inbox_message
|
|
from taskiq_management.broker_setup import MAX_RETRIES,RETRY_DELAY
|
|
from taskiq_management.cv_broker_setup import cv_broker
|
|
|
|
|
|
@cv_broker.task(
|
|
task_name="inbox.match_message",
|
|
retry_on_error=True,
|
|
max_retries=MAX_RETRIES,
|
|
delay=RETRY_DELAY,
|
|
)
|
|
async def match_uploaded_cv(record_id:str,force:bool=False) -> dict:
|
|
return await match_inbox_message(record_id,force)
|