main.py

import os
import pytz

from datetime import datetime
from helpers.pipeline_mode import PipelineMode
from lib.pipeline_controller import PipelineController
from nypl_py_utils.functions.config_helper import load_env_file
from nypl_py_utils.functions.log_helper import create_log


def main():
    load_env_file(os.environ["ENVIRONMENT"], "config/{}.yaml")
    now = datetime.now(pytz.utc).isoformat()
    logger = create_log(__name__)
    controller = PipelineController(now)

    logger.info("Starting new patrons pipeline run")
    controller.run_pipeline(PipelineMode.NEW_PATRONS)

    logger.info("Starting updated patrons pipeline run")
    controller.run_pipeline(PipelineMode.UPDATED_PATRONS)

    logger.info("Starting deleted patrons pipeline run")
    controller.run_pipeline(PipelineMode.DELETED_PATRONS)


if __name__ == "__main__":
    main()