"""Lambda commit_royalties function module."""
from snowflake_connector.etl_connector import SnowflakeSQLExecutor

from commit_royalty.config import SNOWFLAKE_CONFIG
from commit_royalty.processor import CommitRoyaltyProcessor
from commit_royalty.sentry import capture_exception


def handler(event, context):
    """Lambda entry point."""
    try:
        with SnowflakeSQLExecutor(SNOWFLAKE_CONFIG) as sf_executor:
            processor = CommitRoyaltyProcessor(event, sf_executor)
            processor.process()
            return {'status': 'OK'}
    except Exception as e:
        capture_exception(e)
        raise e