def METHOD_NAME(event, context=None, params=None):
    # get UTC date 
    environment = os.environ['environment']
    REGION = os.environ['AWS_REGION']
    utc_datetime = datetime.utcnow()
    year = utc_datetime.strftime('%Y')
    month = utc_datetime.strftime('%m')
    day = utc_datetime.strftime("%d")
    hour = utc_datetime.strftime('%H')
    DATABASE = 'default'
    TABLE = 'formplayer_request_response_logs'
    # S3 constant
    S3_OUTPUT = f"s3://dimagi-commcare-{environment}-logs"
    S3_BUCKET = f"dimagi-commcare-{environment}-logs"
    STREAM_PATH=f"formplayer-request-response-logs-partitioned-{environment}"
    verifyKey = f"{STREAM_PATH}/year={year}/month={month}/day={day}/hour={hour}"
    addPartitionQuery=f"ALTER TABLE {TABLE} ADD PARTITION (year={year}, month={month}, day={day}, hour={hour}) LOCATION 's3://{S3_BUCKET}/{STREAM_PATH}/year={year}/month={month}/day={day}/hour={hour}/';"
    print(addPartitionQuery)
    params = {
        'region': REGION,
        'database': DATABASE,
        'bucket': S3_BUCKET,
        'path': f'{S3_BUCKET}/{STREAM_PATH}/',
        'query': addPartitionQuery
    }
    session = boto3.Session()
    client = session.client('athena')
    key_status = check_file(bucket=S3_BUCKET, key=verifyKey)
    print(key_status)
    if key_status:
        file, response_code = athena_query(session, params)
        print(file, response_code)