From 2657d166cdc62a8e52a38c332efff8c9ce90f49e Mon Sep 17 00:00:00 2001
From: jrybicki-jsc <j.rybicki@fz-juelich.de>
Date: Fri, 6 May 2022 12:00:45 +0200
Subject: [PATCH] pycharm iduced error removed
---
dags/taskflow.py | 12 ++++++------
dags/taskflow_stream.py | 2 +-
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/dags/taskflow.py b/dags/taskflow.py
index bb4abbf..223d3dd 100644
--- a/dags/taskflow.py
+++ b/dags/taskflow.py
@@ -1,16 +1,16 @@
-from airflow.operators.python import PythonOperator
+import json
+import os
+
from airflow.decorators import dag, task
-from airflow.models.connection import Connection
from airflow.models import Variable
+from airflow.models.connection import Connection
+from airflow.operators.python import PythonOperator
from airflow.utils.dates import days_ago
-import os
from datacat_integration.hooks import DataCatalogHook
-import json
-
+from b2shareoperator import download_file, get_file_list, get_object_md
from decors import get_connection, remove, setup
-from b2shareoperator import (download_file, get_file_list, get_object_md)
default_args = {
'owner': 'airflow',
diff --git a/dags/taskflow_stream.py b/dags/taskflow_stream.py
index 2412e62..4b24fbe 100644
--- a/dags/taskflow_stream.py
+++ b/dags/taskflow_stream.py
@@ -1,4 +1,4 @@
-from importlib.metadata import metadata
+
import os
import shutil
import requests
--
GitLab