lekss361/gendesign
1
0
Fork 0
Code Issues 57 Pull requests Projects Releases Packages Wiki Activity Actions

fix(objective parser): use_float=True in ijson + default=str in json.dumps #321

Merged
lekss361 merged 1 commit from fix/obj-decimal-json-serialization into main 2026-05-17 19:11:26 +00:00
Conversation 1 Commits 1 Files changed 1 +4 -4
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
data/sql/70_parse_objective_raw.py
View file

@ -206,7 +206,7 @@ def _row_to_corp_room_month(row: dict, group_name: str, raw_id: int | None) -> d
),
# Audit
"raw_id": raw_id,
"raw_props": json.dumps(row, ensure_ascii=False),
"raw_props": json.dumps(row, ensure_ascii=False, default=str),
}
@ -342,7 +342,7 @@ def _row_to_lot(row: dict, raw_id: int | None, snapshot_date: date) -> dict:
"encumbrance_start_date": _parse_iso_date(row.get("Дата начала обременения")),
"egrn_actual_date": _parse_iso_date(row.get("Дата актуальности данных из ЕГРН")),
"raw_id": raw_id,
"raw_props": json.dumps(row, ensure_ascii=False),
"raw_props": json.dumps(row, ensure_ascii=False, default=str),
"snapshot_date": snapshot_date,
}
@ -543,7 +543,7 @@ def parse_lots_pf_stream(
history_batch: list[dict] = []
batches_since_commit = 0
for row in ijson.items(stream, "result.item"):
for row in ijson.items(stream, "result.item", use_float=True):
if not isinstance(row, dict):
continue
params = _row_to_lot(row, raw_id, snapshot_date)
@ -712,7 +712,7 @@ def parse_lots_pf_stream(
db.execute(_LOTS_HISTORY_INSERT, history_batch)
batch = []
for row in ijson.items(stream, "result.item"):
for row in ijson.items(stream, "result.item", use_float=True):
if not isinstance(row, dict):
continue
params = _row_to_lot(row, raw_id, snapshot_date)