Method save_request

backend/persistence/db.py:42–54

(self, req: dict)

            )

    def save_request(self, req: dict):
        with self._lock, self._conn:
            self._conn.execute(
                """INSERT INTO requests (id, data_type, status, source, priority, submit_time, complete_time, payload)
                   VALUES (?, ?, ?, ?, ?, ?, ?, ?)
                   ON CONFLICT(id) DO UPDATE SET
                       status=excluded.status, complete_time=excluded.complete_time, payload=excluded.payload""",
                (
                    req.get("id"), req.get("data_type"), req.get("status"), req.get("source"),
                    req.get("priority"), req.get("submit_time"), req.get("complete_time"),
                    json.dumps(req, ensure_ascii=False),
                ),
            )

    def load_requests(self):
        with self._lock: