Async in Notifications

[linear[bot]]

In backend/worker/quivr_worker/celery_monitor.py

 # TODO(@aminediro): implement retry  if failure
                    if knowledge_id:
                        await knowledge_service.update_status_knowledge(
                            knowledge_id, KnowledgeStatus.UPLOADED
                        )
                    logger.info(
                        f"task {task.id} process_file_task {task_kwargs} failed. Updating knowledge {knowledge_id} to UPLOADED"
                    )
        except Exception as e:
            logger.exception(f"handling event {event} raised exception: {e}")

    with app.connection() as connection:
        recv = app.events.Receiver(
            connection,
            handlers={
                "task-failed": handle_task_event,  # FIXME: @aminediro check how to handle this
                "task-succeeded": handle_task_event,
            },
        )
        recv.capture(limit=None, timeout=None, wakeup=True)

Unable to call knowledge service in sync notifier;

[linear[bot]]

CORE-142 Async in Notifications