Merge remote-tracking branch 'origin/dev-2.0.0-beta-merge' into featu…

…re-2.0.0-beta-flow_upload
FederatedAI · Jun 20, 2023 · d5aa178 · d5aa178
2 parents 41057bc + faf0d20
commit d5aa178
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/python/fate/arch/computing/standalone/_table.py b/python/fate/arch/computing/standalone/_table.py
@@ -52,7 +52,7 @@ def save(self, uri: URI, schema, options: dict = None):
         if options is None:
             options = {}
 
-        if uri.schema != "eggroll":
+        if uri.schema != "standalone":
             raise ValueError(f"uri scheme `{uri.schema}` not supported with standalone backend")
         try:
             *database, namespace, name = uri.path_splits()

diff --git a/python/fate/components/core/component_desc/artifacts/data/_dataframe.py b/python/fate/components/core/component_desc/artifacts/data/_dataframe.py
@@ -1,3 +1,4 @@
+import logging
 import typing
 
 from fate.components.core.essential import DataframeArtifactType
@@ -8,9 +9,12 @@
     from fate.arch import URI, Context
     from fate.arch.dataframe import DataFrame
 
+logger = logging.getLogger(__name__)
+
 
 class DataframeWriter(_ArtifactTypeWriter["_DataframeArtifactType"]):
     def write(self, ctx, df: "DataFrame", name=None, namespace=None):
+        logger.debug(f"start writing dataframe to artifact: {self.artifact}, name={name}, namespace={namespace}")
         from fate.arch import dataframe
 
         if name is not None:
@@ -26,6 +30,7 @@ def write(self, ctx, df: "DataFrame", name=None, namespace=None):
             schema=self.artifact.metadata.metadata["schema"],
             options=self.artifact.metadata.metadata.get("options", None),
         )
+        logger.debug(f"write dataframe to artifact: {self.artifact}")
 
 
 class DataframeArtifactDescribe(ArtifactDescribe):