Skip to content

Commit 64b8a33

Browse files
authored
update usage of DeserializsedGuard refs (#552)
1 parent 04a3046 commit 64b8a33

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

rust/operator-binary/src/main.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -235,8 +235,8 @@ fn valid_druid_connection_namespace(
235235
let Ok(druid_connection) = &druid_connection.0 else {
236236
return false;
237237
};
238-
druid_connection.druid_namespace().ok() == config_map.meta().namespace
239-
&& Some(druid_connection.druid_name()) == config_map.meta().name
238+
druid_connection.druid_namespace().ok() == config_map.namespace()
239+
&& druid_connection.druid_name() == config_map.name_any()
240240
}
241241

242242
fn valid_druid_job(
@@ -246,6 +246,6 @@ fn valid_druid_job(
246246
let Ok(druid_connection) = &druid_connection.0 else {
247247
return false;
248248
};
249-
druid_connection.metadata.namespace == job.meta().namespace
250-
&& Some(druid_connection.job_name()) == job.meta().name
249+
druid_connection.metadata.namespace == job.namespace()
250+
&& druid_connection.job_name() == job.name_any()
251251
}

0 commit comments

Comments
 (0)