Method log

backend/oasst_backend/journal_writer.py:85–120

(
        self,
        *,
        payload: JournalEvent,
        task_type: str,
        event_type: str = None,
        task_id: Optional[UUID] = None,
        message_id: Optional[UUID] = None,
        commit: bool = True,
    )

    @managed_tx_method(CommitMode.FLUSH)
    def log(
        self,
        *,
        payload: JournalEvent,
        task_type: str,
        event_type: str = None,
        task_id: Optional[UUID] = None,
        message_id: Optional[UUID] = None,
        commit: bool = True,
    ) -> Journal:
        if event_type is None:
            if payload is None:
                event_type = "null"
            else:
                event_type = type(payload).__name__

        if payload.user_id is None:
            payload.user_id = self.user_id
        if payload.message_id is None:
            payload.message_id = message_id
        if payload.task_id is None:
            payload.task_id = task_id
        if payload.task_type is None:
            payload.task_type = task_type

        entry = Journal(
            user_id=self.user_id,
            api_client_id=self.api_client.id,
            created_date=utcnow(),
            event_type=event_type,
            event_payload=PayloadContainer(payload=payload),
            message_id=message_id,
        )

        self.db.add(entry)
        return entry