"""Development handler.""" from datetime import datetime from dotenv import load_dotenv from snowflake_connector.etl_connector import SnowflakeSQLExecutor load_dotenv() # noqa from commit_royalty.config import SNOWFLAKE_CONFIG from commit_royalty.processor import CommitRoyaltyProcessor def run(): """Lambda entry point.""" event = { 'abacus_event_id': 142, 'target_type': 'accounting_run', 'target_id': '1403', 'event_name': 'commit-royalties', 'timestamp': '1997-07-16T19:20:30.45+01:00', 'user_type': 'royalties', 'user_id': '1' } with SnowflakeSQLExecutor(SNOWFLAKE_CONFIG) as sf_executor: processor = CommitRoyaltyProcessor(event, sf_executor) start_time = datetime.now() processor.process() end_time = datetime.now() diff = end_time - start_time print(f'Finished processing in {diff}') if __name__ == '__main__': run()