Hi, I am trying to do a simple pipeline for the Ichimoku cloud indicator. I have done the following, but I receive the following error: 'Latest' object has no attribute 'rolling'. If anyone knows what am I doing incorrectly or knows how to this Pipeline correctly, I would appreciate it.
def make_pipeline():
high_prices = USEquityPricing.high.latest
low_prices = USEquityPricing.low.latest
nine_period_high = high_prices.rolling(window=9).max()
nine_period_low = low_prices.rolling(window=9).min()
tenkan_sen = (nine_period_high + nine_period_low) /2
period26_high = high_prices.rolling(window=26).max()
period26_low = low_prices.rolling(window=26).min()
kijun_sen = (period26_high + period26_low) / 2
senkou_span_a = ((tenkan_sen + kijun_sen) / 2).shift(26)
period52_high = high_prices.rolling(window=52).max()
period52_low = low_prices.rolling(window=52).min()
senkou_span_b = ((period52_high + period52_low) / 2).shift(26)
latest_close = USEquityPricing.close.latest
spread_span_a = latest_close - senkou_span_a
spread_span_b = latest_close - senkou_span_b
spread_span_a_check = spread_span_a > 0
spread_span_b_check = spread_span_b < 0
return pipeline(columns={
'Latest_close':latest_close,
'Long':spread_span_a_check,
'Short':spread_span_b_check,
})