WIP: add logger for monitoring

flyteorg · Jan 10, 2025 · 9b432ea · 9b432ea
1 parent a1c99ec
commit 9b432ea
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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")