def lambda_handler()

in functions/source/Keep-job-alive/keepjobalive.py [0:0]

• 27 lines of code
• 3 McCabe index (conditional complexity)

def lambda_handler(event, context):
    '''
    This lambda is triggered using Cron job
    every 1 minutes (EventBridge CloudWatch Event).
    It requires S3 read/write access to "Production Bucket"

    '''
    print(context)
    print(event)
    # finding MRNs with creation days older than  10 days
    mrns, prs = check_creationtimefile()
    s3_client = boto3.client('s3')

    for i, _ in enumerate(mrns):
        mrn = mrns[i]
        previously_reviewed = prs[i]
        print(mrn)
        bucket = os.environ['FEEDBACK_BUCKET']

        # reading the patient file from source-csv
        key = f'source-csv/{mrn}.csv'
        csv_obj = s3_client.get_object(Bucket=bucket, Key=key)

        body = csv_obj['Body']
        csv_string = body.read().decode('utf-8')
        dataframe = pd.read_csv(StringIO(csv_string))
        # removing that MRN and PR from timeline.csv file
        removerow_creationtime(mrn, previously_reviewed)
        # writing the file back to s3 , inorder to trigger job creation lambda
        write_dataframe_to_csv_on_s3(dataframe, key, bucket)
        print('rewrote to csv')

    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }