Skip to content

Commit ed4f320

Browse files
committed
refactor: rename runDropStage to runDropStageWithRecovery
1 parent 364ecd6 commit ed4f320

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/org/embulk/output/SnowflakeOutputPlugin.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -215,12 +215,12 @@ public ConfigDiff transaction(
215215
snowflakeCon.runCreateStage(stageIdentifier);
216216
configDiff = super.transaction(config, schema, taskCount, control);
217217
if (t.getDeleteStage()) {
218-
runDropStage(snowflakeCon, stageIdentifier, task);
218+
runDropStageWithRecovery(snowflakeCon, stageIdentifier, task);
219219
}
220220
} catch (Exception e) {
221221
if (t.getDeleteStage() && t.getDeleteStageOnError()) {
222222
try {
223-
runDropStage(snowflakeCon, stageIdentifier, task);
223+
runDropStageWithRecovery(snowflakeCon, stageIdentifier, task);
224224
} catch (SQLException ex) {
225225
throw new RuntimeException(ex);
226226
}
@@ -231,7 +231,7 @@ public ConfigDiff transaction(
231231
return configDiff;
232232
}
233233

234-
private void runDropStage(
234+
private void runDropStageWithRecovery(
235235
SnowflakeOutputConnection snowflakeCon, StageIdentifier stageIdentifier, PluginTask task)
236236
throws SQLException {
237237
try {

0 commit comments

Comments
 (0)