# Research environment pipeline imports
from quantopian.pipeline import Pipeline
from quantopian.research import run_pipeline
from quantopian.pipeline.filters import  Q500US

from quantopian.pipeline.data import USEquityPricing 

def make_pipeline():
    
    # Set the base universe of securities
    universe = Q500US()
    
    close = USEquityPricing.close.latest
    closerank = USEquityPricing.close.latest.rank()
    

    return Pipeline(columns={ 
            
            'close': close,
            'closerank': closerank,                
                           
            },
         
            screen=universe)



pipeline_output = run_pipeline(
    make_pipeline(),
    start_date='2020-06-15',
    end_date='2020-06-15',
)

pipeline_output.sort_values('closerank', ascending = False)