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()