Support macOS & Windows and Support Tensorflow >= 2.12.0 (#361)

* support macOS

* modify path with processing '/'

* modify path with processing '/'

easy_rec/python/compat/early_stopping.py

@@ -22,6 +22,8 @@
 import threading
 import time
 
+import tensorflow as tf
+from distutils.version import LooseVersion
 from tensorflow.python.framework import dtypes
 from tensorflow.python.framework import ops
 from tensorflow.python.ops import init_ops
@@ -33,11 +35,15 @@
 from tensorflow.python.training import basic_session_run_hooks
 from tensorflow.python.training import session_run_hook
 from tensorflow.python.training import training_util
-from tensorflow.python.util.tf_export import estimator_export
 
 from easy_rec.python.utils.config_util import parse_time
 from easy_rec.python.utils.load_class import load_by_path
 
+if LooseVersion(tf.__version__) >= LooseVersion('2.12.0'):
+  from tensorflow_estimator.python.estimator.estimator_export import estimator_export
+else:
+  from tensorflow.python.util.tf_export import estimator_export
+
 _EVENT_FILE_GLOB_PATTERN = 'events.out.tfevents.*'
 
 EARLY_STOP_SIG_SCOPE = 'signal_early_stopping'

git-lfs/git_lfs.py

@@ -238,7 +238,8 @@ def get_yes_no(msg):
       if line_str.startswith('#'):
         continue
       line_str = line_str.replace('~/', os.environ['HOME'] + '/')
-      line_str = line_str.replace('${TMPDIR}', os.environ.get('TMPDIR', '/tmp'))
+      line_str = line_str.replace('${TMPDIR}/',
+                                  os.environ.get('TMPDIR', '/tmp/'))
       line_str = line_str.replace('${PROJECT_NAME}', get_proj_name())
       line_tok = [x.strip() for x in line_str.split('=') if x != '']
       if line_tok[0] == 'host':
@@ -363,7 +364,6 @@ def get_yes_no(msg):
       remote_path = git_bin_url[leaf_path][1]
       _, file_name_with_sig = os.path.split(remote_path)
       tar_tmp_path = '%s/%s.tar.gz' % (git_oss_cache_dir, file_name_with_sig)
-
       max_retry = 5
       while max_retry > 0:
         try:
@@ -373,7 +373,13 @@ def get_yes_no(msg):
               oss_bucket.get_object_to_file(remote_path, tar_tmp_path)
             else:
               url = 'http://%s.%s/%s' % (bucket_name, host, remote_path)
-              subprocess.check_output(['wget', url, '-O', tar_tmp_path])
+              # subprocess.check_output(['wget', url, '-O', tar_tmp_path])
+              if sys.platform.startswith('linux'):
+                subprocess.check_output(['wget', url, '-O', tar_tmp_path])
+              elif sys.platform.startswith('darwin'):
+                subprocess.check_output(['curl', url, '--output', tar_tmp_path])
+              elif sys.platform.startswith('win'):
+                subprocess.check_output(['curl', url, '--output', tar_tmp_path])
           else:
             in_cache = True
             logging.info('%s is in cache' % file_name_with_sig)