def callDownstreamLambda()

in lib/analyzer-lambda/analyzer-lambda.py [0:0]

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

def callDownstreamLambda(topic, message):
    log.info(
        'Publishing message to the next lambda for further processing over topic: {0} \n {1}'
        .format(topic, json.dumps(message, indent=2)))
    ggdevice_client.publish(topic=topic, payload=json.dumps(message))