Неважно, что я пу sh, используя xcom_pu sh (), он всегда выбрасывает:
WARNING - /usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py:588: Warning (1300, "Invalid utf8mb4 character string: '800358'") cursor.execute(statement, parameters)
Я знаю, что это xcom_pu sh (), выдавая ошибку потому что, если я закомментирую все xcom_pushes, то предупреждение исчезнет. Я пробовал один xcom_pu sh () с текстом stati c, и я все еще получаю ошибку.
task_instance.xcom_push(key="test", value="test")
Мой бэкэнд - база данных MySql v8.0.19. Любые предложения по исправлению?
Редактировать: база данных была создана следующим образом:
CREATE DATABASE airflow CHARACTER SET utf8 COLLATE utf8_unicode_ci;
Редактировать 2: Я попытался воссоздать базу данных, как показано ниже, но она все еще дает То же предупреждение:
CREATE DATABASE airflow CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;