Create a scheduler

script.py

@tl.job(interval=timedelta(seconds=120))
def sample_job_every_120s():
    weather_response = get_weather_data()
    air_pollution_data = get_air_pollution_data()
    insert_to_mongo(weather_response, air_pollution_data)