diff --git a/viadot/flows/sharepoint_to_adls.py b/viadot/flows/sharepoint_to_adls.py index c2b1a351b..4b0d81b53 100644 --- 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")