优化异步导出,修复临时目录清理逻辑
This commit is contained in:
parent
2e6e665984
commit
079a16bdb7
|
|
@ -151,7 +151,10 @@ func (e *ExportAsync) Run(ctx context.Context) (string, error) {
|
||||||
e.logTool.Errorf("导出panic:\n任务:%s,错误原因:%s", e.task.Id, _err)
|
e.logTool.Errorf("导出panic:\n任务:%s,错误原因:%s", e.task.Id, _err)
|
||||||
}
|
}
|
||||||
e.release()
|
e.release()
|
||||||
|
if e.uploader.Host != "" {
|
||||||
os.RemoveAll(tempDir)
|
os.RemoveAll(tempDir)
|
||||||
|
}
|
||||||
|
|
||||||
cancel()
|
cancel()
|
||||||
}()
|
}()
|
||||||
source, err := e.export(subCtx, tempDir)
|
source, err := e.export(subCtx, tempDir)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue