()
| 336 | |
| 337 | |
| 338 | async def processing_last(): |
| 339 | while True: |
| 340 | last_processed, last_processed_3, last_processed_1, all_df = processed_df() |
| 341 | print('Processing -> Storing processed Files') |
| 342 | last_processed.to_pickle('tickers_df_7.p') |
| 343 | last_processed_3.to_pickle('tickers_df_3.p') |
| 344 | last_processed_1.to_pickle('tickers_df_1.p') |
| 345 | |
| 346 | all_df.to_pickle('all_df.p') |
| 347 | #all_df.to_csv("all_df.csv.gz", compression="gzip") |
| 348 | print('Finished Processing awaiting 120secs') |
| 349 | await asyncio.sleep(120) |
| 350 | |
| 351 | |
| 352 |
no test coverage detected