From 20fce9fb8e55fc02d91fdced66960f69c6e3a11f Mon Sep 17 00:00:00 2001
From: Christian Boettcher <c.boettcher@fz-juelich.de>
Date: Thu, 9 Dec 2021 08:36:19 +0100
Subject: [PATCH] full import paths
---
src/datacat_integration/hooks.py | 4 ++--
src/datacat_integration/operators.py | 2 +-
src/datacat_integration/secrets.py | 4 ++--
3 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/src/datacat_integration/hooks.py b/src/datacat_integration/hooks.py
index 185f5ce..542da6e 100644
--- a/src/datacat_integration/hooks.py
+++ b/src/datacat_integration/hooks.py
@@ -7,9 +7,9 @@ from requests.sessions import session
from requests import Session
from typing import Optional, Dict
-from connection import DataCatConnection, DataCatalogEntry
+from datacat_integration.connection import DataCatConnection, DataCatalogEntry
-from auth import BearerAuth
+from datacat_integration.auth import BearerAuth
def get_connection_from_entry(data: Dict[str, Any], datacat_type: str, oid: str) -> Connection:
diff --git a/src/datacat_integration/operators.py b/src/datacat_integration/operators.py
index 4cb9764..718ee3b 100644
--- a/src/datacat_integration/operators.py
+++ b/src/datacat_integration/operators.py
@@ -1,5 +1,5 @@
from airflow.models.baseoperator import BaseOperator
-from hooks import DataCatalogHook
+from datacat_integration.hooks import DataCatalogHook
class GetDatacatalogEntryOperator(BaseOperator):
"""This task returns the data for an entry in the datacatalog."""
diff --git a/src/datacat_integration/secrets.py b/src/datacat_integration/secrets.py
index d57f0b4..7f389d0 100644
--- a/src/datacat_integration/secrets.py
+++ b/src/datacat_integration/secrets.py
@@ -3,9 +3,9 @@ from urllib.parse import urljoin
from airflow.secrets import BaseSecretsBackend
from airflow.models.connection import Connection
import requests
-from connection import DataCatConnection
-from hooks import DataCatalogHook, get_connection_from_entry
+from datacat_integration.connection import DataCatConnection
+from datacat_integration.hooks import DataCatalogHook, get_connection_from_entry
connection_backend_type = "airflow_connections"
--
GitLab