def log()

in source/client/python/utils/utils/grid_error_logger.py [0:0]

• 29 lines of code
• 5 McCabe index (conditional complexity)

def log(message,
        log_group_name=agent_config_data["error_log_group"],
        log_stream_name=agent_config_data["error_logging_stream"]):
    # print("ERROR-PRINT: {}".format(message))

    try:
        # retreive seq number
        response = cw.describe_log_streams(logGroupName=log_group_name)
        seq = None
        logEvents = [{
            'timestamp': int(time.time() * 1000),
            'message': message
        }
        ]
        for lg in response.get('logStreams'):
            if lg.get('logStreamName') == log_stream_name:
                seq = lg.get('uploadSequenceToken')
        if seq is None:
            response = cw.put_log_events(
                logGroupName=log_group_name,
                logStreamName=log_stream_name,
                logEvents=logEvents
            )
        else:
            response = cw.put_log_events(
                logGroupName=log_group_name,
                logStreamName=log_stream_name,
                logEvents=logEvents,
                sequenceToken=seq
            )
    except Exception as e:
        print("Cannot log errors because {}".format(e), file=sys.stderr)