Remove Single-Client API in oneflow default python

docs/source/oneflow.rst

@@ -36,7 +36,6 @@ oneflow
             cosh, 
             diag, 
             div, 
-            enable_eager_execution, 
             eq, 
             equal, 
             expand, 
@@ -49,7 +48,6 @@ oneflow
             flip, 
             floor, 
             fmod, 
-            function_config, 
             gather, 
             gather_nd, 
             gelu, 
@@ -86,7 +84,6 @@ oneflow
             reciprocal,
             round,  
             save, 
-            saved_model, 
             scatter,
             scatter_add,
             scatter_nd, 

oneflow/api/python/framework/framework.cpp

@@ -25,7 +25,6 @@ ONEFLOW_API_PYBIND11_MODULE("", m) {
   m.def("RegisterGlobalForeignCallback", &RegisterGlobalForeignCallback);
   m.def("DestroyGlobalForeignCallback", &DestroyGlobalForeignCallback);
   m.def("RegisterGlobalWatcher", &RegisterGlobalWatcher);
-  m.def("DestroyGlobalWatcher", &DestroyGlobalWatcher);
   m.def("LaunchJob", &LaunchJob, py::call_guard<py::gil_scoped_release>());
 
   m.def("GetSerializedInterUserJobInfo",

oneflow/api/python/framework/framework.h

@@ -64,13 +64,6 @@ inline Maybe<void> RegisterGlobalWatcher(const std::shared_ptr<ForeignWatcher>&
   return Maybe<void>::Ok();
 }
 
-inline Maybe<void> DestroyGlobalWatcher() {
-  if (Global<std::shared_ptr<ForeignWatcher>>::Get()) {
-    Global<std::shared_ptr<ForeignWatcher>>::Delete();
-  }
-  return Maybe<void>::Ok();
-}
-
 inline Maybe<void> LaunchJob(const std::shared_ptr<oneflow::JobInstance>& cb) {
   CHECK_OR_RETURN(GlobalProcessCtx::IsThisProcessMaster());
   CHECK_NOTNULL_OR_RETURN(Global<Oneflow>::Get());

oneflow/api/python/framework/framework_api.h

@@ -32,8 +32,6 @@ inline void RegisterGlobalWatcher(const std::shared_ptr<oneflow::ForeignWatcher>
   return oneflow::RegisterGlobalWatcher(watcher).GetOrThrow();
 }
 
-inline void DestroyGlobalWatcher() { return oneflow::DestroyGlobalWatcher().GetOrThrow(); }
-
 inline void LaunchJob(const std::shared_ptr<oneflow::JobInstance>& cb) {
   return oneflow::LaunchJob(cb).GetOrThrow();
 }

oneflow/user/kernels/conv_cudnn_kernels.cpp

@@ -371,7 +371,7 @@ class ConvBiasGradGpuKernel final : public user_op::OpKernel {
           new CudnnTensorDesc(CUDNN_TENSOR_NHWC, bias_diff->data_type(), 1,
                               static_cast<int32_t>(bias_diff->shape().At(0)), 1, 1));
     }
-    return std::move(state);
+    return state;
   }
 
  private:

python/oneflow/__init__.py

@@ -91,10 +91,6 @@ def is_deprecated(func_or_class):
 )
 del python_callback
 del register_python_callback
-from oneflow.framework import watcher
-
-oneflow._oneflow_internal.RegisterGlobalWatcher(watcher._global_watcher)
-del watcher
 
 
 def _SyncOnMasterFn():
@@ -147,7 +143,6 @@ def Sync():
 import oneflow.nn.modules.sinh
 import oneflow.nn.modules.tan
 import oneflow.nn.modules.tensor_ops
-import oneflow.tmp
 from oneflow.framework.check_point_v2 import Load as load
 from oneflow.framework.check_point_v2 import save
 from oneflow.framework.dtype import convert_oneflow_dtype_to_numpy_dtype, dtypes
@@ -158,17 +153,10 @@ def Sync():
 from oneflow.framework.function_util import FunctionConfig as function_config
 from oneflow.framework.generator import create_generator as Generator
 from oneflow.framework.generator import default_generator, manual_seed
-from oneflow.framework.model import Model
+
+# NOTE(chengcheng) oneflow.Model is unavailable now.
+# from oneflow.framework.model import Model
 from oneflow.framework.scope_util import api_current_scope as current_scope
-from oneflow.framework.session_util import (
-    api_clear_default_session as clear_default_session,
-)
-from oneflow.framework.session_util import (
-    api_find_or_create_module as find_or_create_module,
-)
-from oneflow.framework.session_util import (
-    api_sync_default_session as sync_default_session,
-)
 from oneflow.framework.tensor import Tensor
 from oneflow.framework.tensor import tensor as tensor
 from oneflow.nn.modules.abs import abs_op as abs
@@ -184,8 +172,6 @@ def Sync():
 from oneflow.nn.modules.activation import selu_op as selu
 from oneflow.nn.modules.activation import softsign_op as softsign
 from oneflow.nn.modules.activation import mish_op as mish
-
-
 from oneflow.nn.modules.adaptive_pool import (
     adaptive_avg_pool1d,
     adaptive_avg_pool2d,
@@ -286,6 +272,7 @@ def Sync():
 from oneflow.nn.modules.sinh import sinh_op as sinh
 from oneflow.nn.modules.slice import slice_op as slice
 from oneflow.nn.modules.slice import slice_update_op as slice_update
+from oneflow.nn.modules.slice import logical_slice_assign_op as logical_slice_assign
 from oneflow.nn.modules.softplus import softplus_op as softplus
 from oneflow.nn.modules.sort import sort_op as sort
 from oneflow.nn.modules.split import split_op as split
@@ -306,8 +293,8 @@ def Sync():
 from oneflow.nn.modules.triu import triu_op as triu
 from oneflow.nn.modules.unsqueeze import unsqueeze_op as unsqueeze
 from oneflow.nn.modules.where import where_op as where
+from oneflow.nn.modules.scatter import *
 from oneflow.ops.builtin_ops import BuiltinOp as builtin_op
-from oneflow.ops.get_variable import api_get_variable as get_variable
 from oneflow.ops.initializer_util import constant_initializer, empty_initializer
 from oneflow.ops.initializer_util import glorot_normal_initializer
 from oneflow.ops.initializer_util import (
@@ -326,8 +313,12 @@ def Sync():
     variance_scaling_initializer,
     zeros_initializer,
 )
-from oneflow.nn.modules.scatter import *
 
-from . import autograd, distributed, linalg, optim, saved_model
+from . import (
+    autograd,
+    distributed,
+    linalg,
+    optim,
+)  # , saved_model NOTE(chengcheng): unavailable now
 import oneflow.utils.data
 import oneflow.utils.vision