diff --git a/zipline/pipeline/loaders/events.py b/zipline/pipeline/loaders/events.py index e88d7966..074ee680 100644 --- a/zipline/pipeline/loaders/events.py +++ b/zipline/pipeline/loaders/events.py @@ -148,7 +148,8 @@ class EventsLoader(PipelineLoader): raise ValueError( WRONG_MANY_COL_DATA_FORMAT_ERROR.format(sid=k) ) - + self.events_by_sid = {sid: df.dropna(subset=self.expected_cols) for + sid, df in self.events_by_sid.iteritems()} self.dataset = dataset def get_loader(self, column):