Remove unused references to tulflow tasks (#1441)

tulibraries · Dec 18, 2023 · 080d450 · 080d450
1 parent 3a4d317
commit 080d450
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/cob_datapipeline/boundwith_move_alma_sftp_to_s3_dag.py b/cob_datapipeline/boundwith_move_alma_sftp_to_s3_dag.py
@@ -2,7 +2,6 @@
 from datetime import datetime, timedelta
 import logging
 import pendulum
-from tulflow import tasks
 import airflow
 from airflow.models import Variable
 from airflow.providers.sftp.hooks.sftp import SFTPHook

diff --git a/cob_datapipeline/catalog_move_alma_sftp_to_s3_dag.py b/cob_datapipeline/catalog_move_alma_sftp_to_s3_dag.py
@@ -2,7 +2,6 @@
 from datetime import datetime, timedelta
 import logging
 import pendulum
-from tulflow import tasks
 import airflow
 from airflow.models import Variable
 from airflow.providers.sftp.hooks.sftp import SFTPHook
@@ -27,7 +26,7 @@
     "on_failure_callback": [slackpostonfail],
     "on_success_callback": [slackpostonsuccess],
     "email_on_retry": False,
-    "on_failure_callback": tasks.execute_slackpostonfail,
+    "on_failure_callback": [slackpostonfail],
     "retries": 5,
     "retry_delay": timedelta(minutes=5),
 }

diff --git a/cob_datapipeline/dspace_harvest_dag.py b/cob_datapipeline/dspace_harvest_dag.py
@@ -2,7 +2,7 @@
 from datetime import datetime, timedelta
 import os
 import pendulum
-from tulflow import harvest, tasks
+from tulflow import harvest
 from cob_datapipeline import helpers
 from airflow.hooks.base import BaseHook
 from airflow.models import Variable