flow fail tests

dyvenia · Nov 24, 2023 · 16e6cb8 · 16e6cb8
1 parent cf31f81
commit 16e6cb8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/viadot/flows/sharepoint_to_adls.py b/viadot/flows/sharepoint_to_adls.py
@@ -21,6 +21,7 @@
 from viadot.tasks import AzureDataLakeUpload
 from viadot.tasks.sharepoint import SharepointToDF, SharepointListToDF
 from prefect.engine.runner import ENDRUN
+from prefect.engine.results import LocalResult
 
 logger = logging.get_logger()
 
@@ -195,7 +196,7 @@ def __init__(self, message):
         self.message = message
 
 
-@task(slug="check_df")
+@task(slug="check_df", result=LocalResult(dir="./results"))
 def check_if_df_empty(df):
     if len(df.index) == 0:
         logger.info("No data in the response. Df empty")