|
@@ -349,10 +349,14 @@ def main() -> int:
|
|
|
run('spectra', [PY, str(ROOT / 'scripts/rudong_tcm_spectra.py'), '--root', str(root),
|
|
run('spectra', [PY, str(ROOT / 'scripts/rudong_tcm_spectra.py'), '--root', str(root),
|
|
|
'--out', str(staging / 'spectra'), '--meas', a.meas, '--jobs', str(a.jobs)]
|
|
'--out', str(staging / 'spectra'), '--meas', a.meas, '--jobs', str(a.jobs)]
|
|
|
+ (['--limit', str(a.limit)] if a.limit else []), log)
|
|
+ (['--limit', str(a.limit)] if a.limit else []), log)
|
|
|
- sm = staging / 'spectra' / 'spectra_meta.parquet'
|
|
|
|
|
- if sm.exists():
|
|
|
|
|
- import pandas as pd
|
|
|
|
|
- n_spectra = len(pd.read_parquet(sm))
|
|
|
|
|
|
|
+ # ★谱数在**两种模式**下都要数 (2026-09-19 远端实逮: --publish-only 那条路把 n_spectra 留在 0,
|
|
|
|
|
+ # 于是清单/报告写"谱 0" —— 明明有 1710 件谱件落着; 清单是给审计对账用的, 少报就是账不实)
|
|
|
|
|
+ sm = staging / 'spectra' / 'spectra_meta.parquet'
|
|
|
|
|
+ if sm.exists():
|
|
|
|
|
+ import pandas as pd
|
|
|
|
|
+ n_spectra = len(pd.read_parquet(sm, columns=['shard']))
|
|
|
|
|
+ elif (staging / 'spectra').is_dir():
|
|
|
|
|
+ n_spectra = sum(1 for _ in (staging / 'spectra').rglob('*.npz'))
|
|
|
|
|
|
|
|
# 窗名: 用数据自身的起始日 (wMMDD), 与既有 w0127/w0707/w0811 同口径
|
|
# 窗名: 用数据自身的起始日 (wMMDD), 与既有 w0127/w0707/w0811 同口径
|
|
|
import pandas as pd
|
|
import pandas as pd
|