mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-10 21:08:14 +08:00
DEP: Remove unecessary calls to write_data
This commit is contained in:
@@ -93,9 +93,6 @@ class RandomWalkSource(DataSource):
|
||||
self.sd = sd
|
||||
|
||||
self.sids = self.start_prices.keys()
|
||||
TradingEnvironment.instance().write_data(
|
||||
equities_identifiers=self.sids
|
||||
)
|
||||
|
||||
self.open_and_closes = \
|
||||
calendar.open_and_closes[self.start:self.end]
|
||||
|
||||
@@ -136,7 +136,6 @@ class SpecificEquityTrades(object):
|
||||
'sids',
|
||||
set(event.sid for event in self.event_list)
|
||||
)
|
||||
env.write_data(equities_identifiers=self.identifiers)
|
||||
assets_by_identifier = {}
|
||||
for identifier in self.identifiers:
|
||||
assets_by_identifier[identifier] = env.asset_finder.\
|
||||
@@ -160,7 +159,6 @@ class SpecificEquityTrades(object):
|
||||
self.concurrent = kwargs.get('concurrent', False)
|
||||
|
||||
self.identifiers = kwargs.get('sids', [1, 2])
|
||||
env.write_data(equities_identifiers=self.identifiers)
|
||||
assets_by_identifier = {}
|
||||
for identifier in self.identifiers:
|
||||
assets_by_identifier[identifier] = env.asset_finder.\
|
||||
|
||||
@@ -119,7 +119,6 @@ def create_trade_history(sid, prices, amounts, interval, sim_params,
|
||||
source_id="test_factory"):
|
||||
trades = []
|
||||
current = sim_params.first_open
|
||||
trading.environment.write_data(equities_identifiers=[sid])
|
||||
|
||||
oneday = timedelta(days=1)
|
||||
use_midnight = interval >= oneday
|
||||
@@ -311,8 +310,6 @@ def create_test_df_source(sim_params=None, bars='daily'):
|
||||
|
||||
df = pd.DataFrame(x, index=index, columns=[0])
|
||||
|
||||
trading.environment.write_data(equities_identifiers=[0])
|
||||
|
||||
return DataFrameSource(df), df
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user