From e4730917a22929d34aa72611db307eb3c03c8a17 Mon Sep 17 00:00:00 2001 From: fawce Date: Tue, 3 Jul 2012 12:19:53 -0400 Subject: [PATCH] hanging chad - forgot to remove the source_id references. --- zipline/finance/sources.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/zipline/finance/sources.py b/zipline/finance/sources.py index eb7c6e9f..0aba2186 100644 --- a/zipline/finance/sources.py +++ b/zipline/finance/sources.py @@ -21,8 +21,7 @@ import zipline.protocol as zp class TradeDataSource(DataSource): - def init(self, source_id): - self.source_id = source_id + def init(self): self.setup_source() #@property @@ -37,14 +36,14 @@ class TradeDataSource(DataSource): :rtype: None """ - event.source_id = self.source_id + event.source_id = self.get_id if event.sid in self.filter['sid']: message = zp.DATASOURCE_FRAME(event) else: blank = ndict({ "type" : zp.DATASOURCE_TYPE.TRADE, - "source_id" : self.source_id + "source_id" : self.get_id }) message = zp.DATASOURCE_FRAME(blank)