def insert_stream_s3()

in PythonKafkaSink/main.py [0:0]

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

def insert_stream_s3(insert_from, insert_into):
    return """INSERT INTO {1}