mycode.py

from multiprocessing import Queue
from fetchers.base import Fetcher
from typing import List
import schedule
import time
import signal
from utils import signal_handler

signal.signal(signal.SIGINT, signal_handler)


def fetch_news(pass_to: Queue, fetchers: List[Fetcher]):
    def put_news_to_query(pass_to: Queue, fetchers: List[Fetcher]):
        for fet in fetchers:
            for news in fet.latest_news():
                pass_to.put(news)

    put_news_to_query(pass_to, fetchers)  # Populate query on startup

    schedule.every(5).minutes.do(put_news_to_query, pass_to, fetchers)
    while True:
        schedule.run_pending()
        time.sleep(5)