"""Kick-off script for sme_analytics_ingestion_flow_control orchestration.""" import json from boto3 import client as boto_client import config from config import app_logger as log def main(): """Logic used by Jenkins to start the flow control Lambda.""" log.info(f'Invoking {config.LAMBDA_NAME}.') lambda_payload = { 'MAX_STATE_MACHINES': int(config.MAX_STATE_MACHINES), 'SFN_START_DELAY': int(config.SFN_START_DELAY), 'SFN_BATCH_SIZE': int(config.SFN_BATCH_SIZE), 'PROCESS_CONFIDENTIAL': config.PROCESS_CONFIDENTIAL, } aws_lambda_client = boto_client('lambda', region_name='us-east-1') aws_lambda_client.invoke( FunctionName=f'{config.LAMBDA_NAME}', InvocationType='Event', Payload=bytes(json.dumps(lambda_payload), 'utf-8'), ) log.info(f'Invoked {config.LAMBDA_NAME}.') log.info(f'Lambda payload : {lambda_payload}.') if __name__ == '__main__': main()