Живой вход ECS в Cloudwatch

Я использую задачу ECS, которая запускает контейнер Docker для выполнения некоторых команд terraform.

Я хотел бы регистрировать результаты команд terraform в Cloudwatch, если это возможно, в реальном времени. Я использую пакет протоколирование Python 3.

Функция, которую я использую для вывода результата команды, следующая:

def execute_command(command):
    """
    This method is used to execute the several commands
    :param command: The command to be executed
    :return decoded: The result of the command execution
    """

    logging.info('Executing: {}'.format(command))
    process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)

    communicate = process.communicate()
    decoded = (communicate[0].decode('utf-8'), communicate[1].decode('utf-8'))

    for stdout in decoded[0].split('\n'):
        if stdout != '':
            logging.info(stdout)

    for stderr in decoded[1].split('\n'):
        if stderr != '':
            logging.warning(stderr)

    return decoded

Который называется следующим образом:

apply_command = 'terraform apply -input=false -auto-approve -no-color {}'.format(plan_path)
terraform_apply_output = utils.execute_command(apply_command)

if terraform_apply_output[1] is not '':
   logging.info('Apply has failed. See above logs')
   aws_utils.remove_message_from_queue(metadata['receipt_handle'])
   utils.exit_pipeline(1)

Когда команда terraform завершается успешно, я вижу ее вывод после, команда была выполнена (т. е. я вижу результат команды применения после применения ресурсов), что и ожидается кодом.

Когда команда terraform не удалась (скажем, из-за того, что некоторые ресурсы уже были развернуты и не сохранены в .tfstate), я не вижу входа в систему, и задача ECS завершается без сообщения об ошибке.

Я вижу 2 причины этому:

1. Результат неудачной команды terraform возвращает ненулевой код, что означает, что задача ECS завершается до вывода журналов в стандартный вывод (и, следовательно, в Cloudwatch).
2. Результат неудачной команды terraform отправляется в stderr, который неправильно регистрируется.

В чем здесь моя ошибка и как я могу ее исправить? Любая помощь очень ценится :)