diff --git a/zipline/pipeline/pipeline.py b/zipline/pipeline/pipeline.py index 78ee5ed5..e7c6b4de 100644 --- a/zipline/pipeline/pipeline.py +++ b/zipline/pipeline/pipeline.py @@ -229,6 +229,7 @@ class Pipeline(object): raise AssertionError("Unknown graph format %r." % format) @staticmethod + @expect_types(term=Term, column_name=str) def validate_column(column_name, term): if term.ndim == 1: raise UnsupportedPipelineOutput(column_name=column_name, term=term)