【Python/Gmail/GmailAPI】任意のメール内のスレッドIDに返信メールを送りたい

Question

Python版Gmail API ClientでThreadにメール(返信)を送信する

上記のサイトを参考に、Pythonを使ってGmailの返信機能の実装を目指しています。
今書いているコードがこのような感じです。

import pickle
import os.path
from googleapiclient.discovery import build
from google_auth_oauthlib.flow import InstalledAppFlow
from google.auth.transport.requests import Request
import base64
from email.mime.text import MIMEText
from apiclient import errors
import json

SCOPES = ['https://mail.google.com/',
          'https://www.googleapis.com/auth/gmail.send',
          'https://www.googleapis.com/auth/gmail.readonly',
]

def create_message(sender, to, subject, message_text,
                   thread_id=None, reply_to=None, past_message=None):
    if past_message:
        message_text = message_text + '\r\n\r\n'
        for strline in past_message.splitlines(): # 過去のメッセージを一行ずつ分割
            message_text = message_text + '\r\n>' + strline # 手で改行 + '>'を追加
    message = MIMEText(message_text)
    message['to'] = to
    message['from'] = sender
    message['subject'] = subject
    if reply_to:
        message['Reference'] = reply_to
        message['In-Reply-To'] = reply_to
    raw_msg = base64.urlsafe_b64encode(message.as_bytes())
    raw_msg = raw_msg.decode()
    raw_msg = {'raw': raw_msg}
    if thread_id:
        raw_msg['threadId'] = thread_id
    return raw_msg


def send_message(service, user_id, message):
    try:
        message = service.users().messages().send(userId=user_id, body=message).execute()
        print('Message Id: %s' %message['id'])
        return message
    except errors.HttpError as error:
        print('An error ocurred: %s' % error)

### Thread IDを取得する
def get_thread_list(service, user_id, query):
    return service.users().threads().list(userId=user_id, q=query).execute()

### メッセージの中身を取得する
def get_thread(service, user_id, thread_id):
    return service.users().threads().get(userId=user_id, id=thread_id).execute()

def main():
    creds = None
    if os.path.exists('token.pickle'):
        with open('token.pickle','rb') as token:
            creds = pickle.load(token)

    if not creds or not creds.valid:
        if creds and creds.expired and creds.refresh_token:
            creds.refresh(Request())
        else:
            flow = InstalledAppFlow.from_client_secrets_file(
                'credentials.json', SCOPES)
            creds = flow.run_local_server()

        with open('token.pickle', 'wb') as token:
            pickle.dump(creds, token)

    service = build('gmail','v1',credentials=creds)

##### 一発目(threadが立っていない)のときにコメントアウト #####
    query = 'in:sent' # 自分が送信したThreadを検索
    thread_list = get_thread_list(service,'me',query) # jsonをdictionaryにdumpしたものが帰ってくる
    thread_id = thread_list['threads'][0]['id']
    print(thread_id) # 検索の最初のThreadのthreadIdが出力される
    thread = get_thread(service,'me',thread_id)
    latest_message = thread['messages'][-1]['payload'] # threadの一番最後のメッセージオブジェクトを取得
    latest_msg_body = base64.urlsafe_b64decode(latest_message['body']['data']).decode() # base64形式なのでstringにdecodeする

    ###ついでに、ここからReplyするメッセージIDをHeaderから取得しておく
    for att in latest_message['headers']:
        if att['name'] == 'Message-Id':
            message_id = att['value']
            break
##### コメントアウトおわり ######

    sender = '******@******'
    to = '######@######'
    subject = 'Gmail API test'
#    message_text = 'This mail is sent via the Gmail API' # 1回目(reply_toとthread_idは定義しない)
    message_text = 'This mail is test for sending to the same thread' # 2回目
#    message_text = 'This mail is test for sending to the same thread (2nd)' #3回目

#    message = create_message(sender, to, subject, message_text) # 一発目のみ
    message = create_message(sender, to, subject, message_text, thread_id, message_id, latest_msg_body)
    send_message(service, 'me', message)

if __name__ == '__main__':
    main()

こちらのリンクを参考にしてみたのですが、メッセージIDを指定して実行しても新着メールとして届いてしまいます。。
メッセージIDで検索し、その中の最新のスレッドIDに返信をするには何か設定が足りないのでしょうか。
もしわかる方いたら教えてください。

よろしくお願いします。

<補足>
GmailのメッセージIDとスレッドIDもPythonで取得しており、こちらは問題なく取得できています。

Answer 1

下記の内容で、threadIdを直打ちしたら、返信できたことが確認されました。
あとは、スレッドIDの有無を条件分岐うまく作って実装してみたいと思います。
解決に向けてご助力いただいた方々ありがとうございました。

if thread_id:
        raw_msg['threadId'] = thread_id
    return raw_msg