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)