diff --git a/dags/taskflow.py b/dags/taskflow.py index bb4abbf8eefe8041d6321434635688c91af74fa3..223d3dde9e7550121ce4bfd1e08722830667d257 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 2412e625f09ad1d078ae38349121c26e942dc4c4..4b24fbe8d1ebd14ff54edd4aa5107a8070610358 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