jgtpricedb 0.2.0
“Database-backed incremental price store for the JGT trading platform (PDSP heir)”
SQLAlchemy ORMWrites bytes with pathlib.Path.write_bytes()
SHA-256b328d77ea8de42df9d5cf5e945aee2a861a7bec159fe7af067fd7c402ce8d5e8
MaleculeH₂(Db₂F)
Evidence
140:2… path = Path(path)
141 try:
142 with path.open("rb") as handle:
143 chunk = handle.read(8192)
144 except OSError:
145 return None
⋯4 lines
418:29… ad: bytes, *, atomic: bool) -> None:
419 if not atomic:
420 path.write_bytes(payload)
421 return
422 staging = path.with_name(f".{path.name}.{os.getpid()}.tmp")
423 try:
424 staging.write_bytes(payload)
425 os.replace(staging, path)
426 finally:
427 if staging.exists(): # pragma: no cover - f …
12:41…
13from typing import Iterator, Literal, Protocol, Sequence
14
15from sqlalchemy import (Engine, create_engine, delete, event, func, insert, select,
16 update)
17from sqlalchemy.exc import IntegrityError
18from sqlalchemy.orm import Session, sessionmaker
19
20from .identity import pov as make_pov
21from .markets import classify_market
22from .models import (
⋯8 lines
9from datetime import datetime, timezone
10
11from sqlalchemy import (
12 BigInteger,
13 Boolean,
⋯6 lines
277:16… Mapped[datetime] = mapped_column(UtcInstant, nullable=False)
278
279
280Index("ux_bars_key", Bar.bar_key, unique=True)
281
282#: C1 / I2 — at most one forming bar per series, enforced by the database.
283Index(
284 "ux_bars_forming",
285 Bar.series_id,
⋯6 lines
No evidence locations were recorded for this file. Raw result