diff --git a/flytekit/types/structured/basic_dfs.py b/flytekit/types/structured/basic_dfs.py index f9f5d536a6..abc5c2624d 100644 --- a/flytekit/types/structured/basic_dfs.py +++ b/flytekit/types/structured/basic_dfs.py @@ -134,6 +134,7 @@ def decode( if current_task_metadata.structured_dataset_type and current_task_metadata.structured_dataset_type.columns: columns = [c.name for c in current_task_metadata.structured_dataset_type.columns] try: + logger.debug(f"structured data uri: {uri}") return pd.read_parquet(uri, columns=columns, storage_options=kwargs) except NoCredentialsError: logger.debug("S3 source detected, attempting anonymous S3 access")