Skip to content

Commit e79ad63

Browse files
authored
Avoid catalog queries with BacktestNode.download_data (#2740)
1 parent c91ec7a commit e79ad63

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

nautilus_trader/backtest/node.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -338,6 +338,11 @@ def download_data(
338338

339339
kwargs["update_catalog"] = True
340340
params = kwargs.get("params", {})
341+
342+
# No need to do catalog queries when we just want to download and store data
343+
params["skip_catalog_data"] = True
344+
345+
# To be able to download future data if necessary
341346
params["subscription_name"] = "download"
342347
kwargs["params"] = params
343348

nautilus_trader/data/engine.pyx

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1462,7 +1462,8 @@ cdef class DataEngine(Component):
14621462
if has_catalog_data:
14631463
break
14641464

1465-
n_requests = (len(missing_intervals) if used_client else 0) + (1 if has_catalog_data else 0)
1465+
skip_catalog_data = request.params.get("skip_catalog_data", False)
1466+
n_requests = (len(missing_intervals) if used_client else 0) + (1 if has_catalog_data and not skip_catalog_data else 0)
14661467

14671468
if n_requests == 0:
14681469
response = DataResponse(
@@ -1480,7 +1481,7 @@ cdef class DataEngine(Component):
14801481
self._new_query_group(request.id, n_requests)
14811482

14821483
# Catalog query
1483-
if has_catalog_data:
1484+
if has_catalog_data and not skip_catalog_data:
14841485
new_request = request.with_dates(start, end, now.value)
14851486
new_request.params["request_ts_start"] = start.value
14861487
new_request.params["request_ts_end"] = end.value

0 commit comments

Comments
 (0)