code: def test_kinesis_streams():
      """CLI - Terraform Generate Kinesis Streams"""
      cluster_dict = common.infinitedict()
      result = kinesis_streams.generate_kinesis_streams(
          "advanced", cluster_dict, CONFIG
      )
  
      expected_result = {
          "module": {
              "kinesis_advanced": {
                  "source": "./modules/tf_kinesis_streams",
                  "account_id": "12345678910",
                  "shard_level_metrics": ["IncomingBytes"],
                  "region": "us-west-1",
                  "prefix": "unit-test",
                  "cluster": "advanced",
                  "stream_name": "unit-test_advanced_streamalert",
                  "shards": 1,
                  "retention": 24,
                  "create_user": True,
                  "trusted_accounts": [],
              }
          },
          "output": {
              "kinesis_advanced_access_key_id": {
                  "value": "${module.kinesis_advanced.access_key_id}"
              },
              "kinesis_advanced_secret_key": {
                  "value": "${module.kinesis_advanced.secret_key}"
              },
              "kinesis_advanced_user_arn": {
                  "value": "${module.kinesis_advanced.user_arn}"
              },
          },
      }
  
      assert_true(result)
      assert_equal(cluster_dict, expected_result)
  
imports: from nose.tools import assert_equal, assert_true
  from streamalert_cli.config import CLIConfig
  from streamalert_cli.terraform import common, kinesis_streams
label_desc: Use image node_id 1 for calling a global function with example usage: test_kinesis_streams() without return types