fetch_forecast: API endpoint defined in init

src/fetch_forecast.py

@@ -19,6 +19,7 @@ class FetchForecast:
         self.ticker = ticker
         # constants
         self.past_horizon = 5  # number of past business days
+        self.endpoint = "v1/forecast/from_symbol"
         # build the api-url based on env variables
         self.api_env = os.environ.get("FORECAST_API_ENV")
         api_url_temp = os.environ.get("API_URL_TEMPLATE")
@@ -31,7 +32,7 @@ class FetchForecast:
     def call_api(self) -> tuple:
         pl_in = {"ticker": self.ticker, "past_horizon": self.past_horizon}
         self.logger.info(f"Calling forecast API ({self.api_env}) for ticker: {self.ticker}")
-        resp = requests.post(f"{self.api_url}/forecast", json=pl_in, timeout=30)
+        resp = requests.post(f"{self.api_url}/{self.endpoint}", json=pl_in, timeout=30)
         if resp.status_code == 200:
             data = resp.json()
             past_df, fcst_df = self.transform_data(data)