(self,
stocks = None,
start_date = None,
end_date = None)
| 608 | df.to_parquet(os.path.join(self.root, self.workdir, self.tag, "economic.parquet"), index=False) |
| 609 | |
| 610 | def process(self, |
| 611 | stocks = None, |
| 612 | start_date = None, |
| 613 | end_date = None): |
| 614 | |
| 615 | print(">" * 30 + "Running price and features..." + ">" * 30) |
| 616 | self._process_price_and_features(stocks=stocks, start_date=start_date, end_date=end_date) |
| 617 | print("<" * 30 + "Finish price and features..." + "<" * 30) |
| 618 | |
| 619 | if "guidance" in self.path_params: |
| 620 | print(">" * 30 + "Running guidance..." + ">" * 30) |
| 621 | self._process_guidance(stocks=stocks, start_date=start_date, end_date=end_date) |
| 622 | print("<" * 30 + "Finish guidance..." + "<" * 30) |
| 623 | |
| 624 | if "sentiment" in self.path_params: |
| 625 | print(">" * 30 + "Running sentiment..." + ">" * 30) |
| 626 | self._process_sentiment(stocks=stocks, start_date=start_date, end_date=end_date) |
| 627 | print("<" * 30 + "Finish sentiment..." + "<" * 30) |
| 628 | |
| 629 | print(">" * 30 + "Running news..." + ">" * 30) |
| 630 | self._process_news(stocks=stocks, start_date=start_date, end_date=end_date) |
| 631 | print("<" * 30 + "Finish news..." + "<" * 30) |
| 632 | |
| 633 | if "economic" in self.path_params: |
| 634 | print(">" * 30 + "Running economic..." + ">" * 30) |
| 635 | self._process_economic(stocks=stocks, start_date=start_date, end_date=end_date) |
| 636 | print("<" * 30 + "Finish economic..." + "<" * 30) |
no test coverage detected