Skip to content

Commit 9900030

Browse files
authored
fix(mysql-schema): use proper secondary resource type (#1103)
1 parent fcdcb04 commit 9900030

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/MySQLSchemaReconciler.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import io.javaoperatorsdk.operator.api.reconciler.dependent.Dependent;
1414
import io.javaoperatorsdk.operator.sample.dependent.SchemaDependentResource;
1515
import io.javaoperatorsdk.operator.sample.dependent.SecretDependentResource;
16+
import io.javaoperatorsdk.operator.sample.schema.Schema;
1617

1718
import static io.javaoperatorsdk.operator.sample.dependent.SchemaDependentResource.decode;
1819
import static io.javaoperatorsdk.operator.sample.dependent.SecretDependentResource.MYSQL_SECRET_USERNAME;
@@ -37,10 +38,10 @@ public UpdateControl<MySQLSchema> reconcile(MySQLSchema schema, Context<MySQLSch
3738
// context
3839
Secret secret = context.getSecondaryResource(Secret.class).orElseThrow();
3940

40-
return context.getSecondaryResource(MySQLSchema.class, SchemaDependentResource.NAME).map(s -> {
41+
return context.getSecondaryResource(Schema.class, SchemaDependentResource.NAME).map(s -> {
4142
updateStatusPojo(schema, secret.getMetadata().getName(),
4243
decode(secret.getData().get(MYSQL_SECRET_USERNAME)));
43-
log.info("Schema {} created - updating CR status", schema.getMetadata().getName());
44+
log.info("Schema {} created - updating CR status", s.getName());
4445
return UpdateControl.updateStatus(schema);
4546
}).orElse(UpdateControl.noUpdate());
4647
}

0 commit comments

Comments
 (0)