Skip to content

Commit 1391707

Browse files
committed
chore: Use delayed controller
1 parent 1015d2a commit 1391707

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

rust/operator-binary/src/main.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -251,10 +251,16 @@ async fn main() -> anyhow::Result<()> {
251251
zk_controller.await
252252
};
253253

254+
let delayed_znode_controller = async {
255+
signal::crd_established(&client, v1alpha1::ZookeeperZnode::crd_name(), None)
256+
.await?;
257+
znode_controller.await
258+
};
259+
254260
// kube-runtime's Controller will tokio::spawn each reconciliation, so this only concerns the internal watch machinery
255261
futures::try_join!(
256262
delayed_zk_controller,
257-
znode_controller,
263+
delayed_znode_controller,
258264
eos_checker,
259265
webhook_server
260266
)?;

0 commit comments

Comments
 (0)