mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-03 08:51:59 +08:00
hanging chad - forgot to remove the source_id references.
This commit is contained in:
@@ -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)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user