| 12345678 |
- from paddle.distributed.fleet.utils import HDFSClient
- class MyHDFSClient(HDFSClient):
- def _run_safe_cmd(self, cmd, redirect_stderr=False, retry_times=5):
- cmdStr = " ".join(cmd)
- ret, lines = super()._run_safe_cmd(self, cmdStr, redirect_stderr, retry_times)
- log.info("cmdStr: {} ret: {} lines: {}".format(cmdStr,ret,lines))
- return ret, lines
|
