refactor: rename runDropStage to runDropStageWithRecovery

trocco-io · Nov 7, 2024 · f383ccf · f383ccf
1 parent 364ecd6
commit f383ccf
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java b/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java
@@ -215,12 +215,12 @@ public ConfigDiff transaction(
       snowflakeCon.runCreateStage(stageIdentifier);
       configDiff = super.transaction(config, schema, taskCount, control);
       if (t.getDeleteStage()) {
-        runDropStage(snowflakeCon, stageIdentifier, task);
+        runDropStageWithRecovery(snowflakeCon, stageIdentifier, task);
       }
     } catch (Exception e) {
       if (t.getDeleteStage() && t.getDeleteStageOnError()) {
         try {
-          runDropStage(snowflakeCon, stageIdentifier, task);
+          runDropStageWithRecovery(snowflakeCon, stageIdentifier, task);
         } catch (SQLException ex) {
           throw new RuntimeException(ex);
         }
@@ -231,7 +231,7 @@ public ConfigDiff transaction(
     return configDiff;
   }
 
-  private void runDropStage(
+  private void runDropStageWithRecovery(
       SnowflakeOutputConnection snowflakeCon, StageIdentifier stageIdentifier, PluginTask task)
       throws SQLException {
     try {