(paragraph_id_list, model_id)
| 54 | |
| 55 | @celery_app.task(base=QueueOnce, once={"keys": ["paragraph_id_list"]}, name="celery:embedding_by_paragraph_list") |
| 56 | def embedding_by_paragraph_list(paragraph_id_list, model_id): |
| 57 | embedding_model = get_embedding_model(model_id) |
| 58 | ListenerManagement.embedding_by_paragraph_list(paragraph_id_list, embedding_model) |
| 59 | |
| 60 | |
| 61 | @celery_app.task(base=QueueOnce, once={"keys": ["document_id"]}, name="celery:embedding_by_document") |
no test coverage detected