| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 | import datetimeimport loggingimport timeimport clickfrom werkzeug.exceptions import NotFoundfrom core.indexing_runner import DocumentIsPausedError, IndexingRunnerfrom events.event_handlers.document_index_event import document_index_createdfrom extensions.ext_database import dbfrom models.dataset import Document@document_index_created.connectdef handle(sender, **kwargs):    dataset_id = sender    document_ids = kwargs.get("document_ids")    documents = []    start_at = time.perf_counter()    for document_id in document_ids:        logging.info(click.style("Start process document: {}".format(document_id), fg="green"))        document = (            db.session.query(Document)            .filter(                Document.id == document_id,                Document.dataset_id == dataset_id,            )            .first()        )        if not document:            raise NotFound("Document not found")        document.indexing_status = "parsing"        document.processing_started_at = datetime.datetime.now(datetime.UTC).replace(tzinfo=None)        documents.append(document)        db.session.add(document)    db.session.commit()    try:        indexing_runner = IndexingRunner()        indexing_runner.run(documents)        end_at = time.perf_counter()        logging.info(click.style("Processed dataset: {} latency: {}".format(dataset_id, end_at - start_at), fg="green"))    except DocumentIsPausedError as ex:        logging.info(click.style(str(ex), fg="yellow"))    except Exception:        pass
 |