gitadmin/fxhnt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(orchestration): serialize futures_bars after crypto_bars (DuckDB single-writer lock)

Browse Source 
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This commit is contained in:
jgrusewski
2026-06-15 15:15:48 +02:00
parent bf2029868b
commit f628d78cbb
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/fxhnt/adapters/orchestration/assets.py
View File

@@ -51,7 +51,7 @@ def crypto_bars(context: AssetExecutionContext) -> int:
return n
@asset
@asset(deps=[crypto_bars]) # serialize after crypto_bars: DuckDB is single-writer (one lock on warehouse.duckdb)
def futures_bars(context: AssetExecutionContext) -> int:
"""Bronze → silver → warehouse: ingest continuous front-month futures arrays.