Method run

python/pathway/tests/test_sqlite.py:608–612

(self)

            return True

        def run(self):
            row = b'{"b": "B", "a": "A"}'
            self._add(api.ref_scalar(1), row)
            self.commit()  # force the remove into a separate minibatch
            self._remove(api.ref_scalar(1), row)

    t = pw.io.python.read(Subject(), schema=S, autocommit_duration_ms=1)
    pw.io.sqlite.write(