revert error handling of io err AlreadyExists
@@ -55,14 +55,7 @@ impl Interpreter for CreateUserStageInterpreter {
if user_stage.stage_type == StageType::Internal {
let prefix = format!("stage/{}/", user_stage.stage_name);
let op = self.ctx.get_storage_operator()?;
- op.object(&prefix).create().await.or_else(|e| {
- if e.kind() == std::io::ErrorKind::AlreadyExists {
- // if target path already exist, just ignore the error
- Ok(())
- } else {
- Err(e)
- }
- })?;
+ op.object(&prefix).create().await?
}
let _create_stage = user_mgr
