Skip to content

Commit 98fe1ae

Browse files
fix(cli): metadata commands weren't working with external storages (#12743)
closes #12713
1 parent 1143caf commit 98fe1ae

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

cli/src/main/java/io/kestra/cli/commands/migrations/metadata/KvMetadataMigrationCommand.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.kestra.cli.AbstractCommand;
44
import jakarta.inject.Inject;
5+
import jakarta.inject.Provider;
56
import lombok.extern.slf4j.Slf4j;
67
import picocli.CommandLine;
78

@@ -12,13 +13,13 @@
1213
@Slf4j
1314
public class KvMetadataMigrationCommand extends AbstractCommand {
1415
@Inject
15-
private MetadataMigrationService metadataMigrationService;
16+
private Provider<MetadataMigrationService> metadataMigrationServiceProvider;
1617

1718
@Override
1819
public Integer call() throws Exception {
1920
super.call();
2021
try {
21-
metadataMigrationService.kvMigration();
22+
metadataMigrationServiceProvider.get().kvMigration();
2223
} catch (Exception e) {
2324
System.err.println("❌ KV Metadata migration failed: " + e.getMessage());
2425
e.printStackTrace();

cli/src/main/java/io/kestra/cli/commands/migrations/metadata/SecretsMetadataMigrationCommand.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.kestra.cli.AbstractCommand;
44
import jakarta.inject.Inject;
5+
import jakarta.inject.Provider;
56
import lombok.extern.slf4j.Slf4j;
67
import picocli.CommandLine;
78

@@ -12,13 +13,13 @@
1213
@Slf4j
1314
public class SecretsMetadataMigrationCommand extends AbstractCommand {
1415
@Inject
15-
private MetadataMigrationService metadataMigrationService;
16+
private Provider<MetadataMigrationService> metadataMigrationServiceProvider;
1617

1718
@Override
1819
public Integer call() throws Exception {
1920
super.call();
2021
try {
21-
metadataMigrationService.secretMigration();
22+
metadataMigrationServiceProvider.get().secretMigration();
2223
} catch (Exception e) {
2324
System.err.println("❌ Secrets Metadata migration failed: " + e.getMessage());
2425
e.printStackTrace();

0 commit comments

Comments
 (0)