Fix bug on inputs for jobs.

Author: qiuosier

ads/jobs/builders/infrastructure/dsc_job_runtime.py

@@ -1101,7 +1101,10 @@ def _extract_envs(self, dsc_job) -> dict:
         # Inputs
         input_mappings = envs.pop(driver_utils.CONST_ENV_INPUT_MAPPINGS, None)
         if input_mappings:
-            spec[PyTorchDistributedRuntime.CONST_INPUT] = input_mappings
+            try:
+                spec[PyTorchDistributedRuntime.CONST_INPUT] = json.loads(input_mappings)
+            except ValueError:
+                spec[PyTorchDistributedRuntime.CONST_INPUT] = input_mappings
         # Dependencies
         dep = {}
         if driver_utils.CONST_ENV_PIP_PKG in envs:

ads/jobs/templates/driver_utils.py

@@ -283,7 +283,9 @@ def copy_inputs(mappings: dict = None):
             else:
                 dest_dir = os.path.dirname(dest)
 
-            os.makedirs(dest_dir, exist_ok=True)
+            # Do not make dirs if user is using cwd.
+            if dest_dir:
+                os.makedirs(dest_dir, exist_ok=True)
 
             # Use native Python to download http/ftp.
             scheme = urlparse(src).scheme