Ошибка при создании DAG. Синтаксическая ошибка в DAG

Question

Я пытаюсь создать тег для выполнения какого-либо запроса в улье с помощью hiveoperator. Код написан ниже:

import datetime as dt

from airflow.models import DAG
from airflow.operators.hive_operator import HiveOperator

default_args = {
    'owner': 'airflow',
    'start_date': dt.datetime(2020, 3, 24),
    'retries': 1,
    'retry_delay': dt.timedelta(minutes=5),
}

hql_query = """USE testdb;
CREATE TABLE airflow-test-table LIKE test_table;"""

dag = DAG(
    dag_id='load-hive',
    default_args=default_args,
    schedule_interval='0 * * * *'
)

hive-copy = HiveOperator(
    task_id="hive-copy",
    hql=hql_query,
    hive_cli_conn_id="dime_hive_cli_default",
    dag=load-hive,
)

hive-copy

Я получаю синтаксическую ошибку:

Невозможно назначить синтаксическую ошибку оператора в hive-copy = HiveOperator (строка

. Я не уверен, что происходит не так.

Answer 1

Не используйте da sh '-' в hive-copy, переименуйте его в hive_copy