diff --git a/plugins/databricks/databricks_operator.py b/plugins/databricks/databricks_operator.py index 865df269..7109bc1c 100644 --- a/plugins/databricks/databricks_operator.py +++ b/plugins/databricks/databricks_operator.py @@ -26,7 +26,7 @@ import six import time from airflow.exceptions import AirflowException -from .databricks_hook import DatabricksHook +from databricks.databricks_hook import DatabricksHook from airflow.models import BaseOperator from airflow.utils.decorators import apply_defaults