from quantopian.pipeline import Pipeline
from quantopian.research import run_pipeline
from quantopian.pipeline.data.user_5a9647710bf8210015eea461 import yield_spy_final
pipe = Pipeline(
columns={
'yield': yield_spy_final.yield_.latest,
'spy' : yield_spy_final.spy.latest
},
screen=yield_spy_final.yield_.latest.notnull()
)
df = run_pipeline(pipe, '2002-01-03', '2018-06-04')
df.head()