From f628d78cbbaadca1f8c97c515796f0ef9fda573e Mon Sep 17 00:00:00 2001
From: jgrusewski <jgrusewski@localhost>
Date: Mon, 15 Jun 2026 15:15:48 +0200
Subject: [PATCH] fix(orchestration): serialize futures_bars after crypto_bars
 (DuckDB single-writer lock)

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
---
 src/fxhnt/adapters/orchestration/assets.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/fxhnt/adapters/orchestration/assets.py b/src/fxhnt/adapters/orchestration/assets.py
index 87130c5..02e1d39 100644
--- a/src/fxhnt/adapters/orchestration/assets.py
+++ b/src/fxhnt/adapters/orchestration/assets.py
@@ -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.