From 4fd9bcd2dd62c337279664ed1b56d9c5da6bfb72 Mon Sep 17 00:00:00 2001 From: MG190202 Date: Tue, 27 Feb 2024 19:51:17 +0530 Subject: [PATCH 1/2] Remove assertion bug --- dozer-sink-aerospike/src/lib.rs | 1 - 1 file changed, 1 deletion(-) diff --git a/dozer-sink-aerospike/src/lib.rs b/dozer-sink-aerospike/src/lib.rs index ac3f79d4fd..843c534a20 100644 --- a/dozer-sink-aerospike/src/lib.rs +++ b/dozer-sink-aerospike/src/lib.rs @@ -1190,7 +1190,6 @@ impl Sink for AerospikeSink { } fn process(&mut self, op: TableOperation) -> Result<(), BoxedError> { - debug_assert_eq!(op.port, DEFAULT_PORT_HANDLE); self.sender.send(op)?; Ok(()) } From 519ce033e18879939fa1c9136f23ea942ffbea34 Mon Sep 17 00:00:00 2001 From: MG190202 Date: Tue, 27 Feb 2024 20:01:54 +0530 Subject: [PATCH 2/2] Resolve lint errors --- dozer-sink-aerospike/src/lib.rs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/dozer-sink-aerospike/src/lib.rs b/dozer-sink-aerospike/src/lib.rs index 843c534a20..abfc893ffc 100644 --- a/dozer-sink-aerospike/src/lib.rs +++ b/dozer-sink-aerospike/src/lib.rs @@ -35,10 +35,8 @@ use aerospike_client_sys::{ as_val_val_reserve, as_vector, as_vector_increase_capacity, as_vector_init, AS_BATCH_WRITE, AS_BIN_NAME_MAX_LEN, }; -use dozer_core::{ - node::{PortHandle, Sink, SinkFactory}, - DEFAULT_PORT_HANDLE, -}; +use dozer_core::node::{PortHandle, Sink, SinkFactory}; +pub const DEFAULT_PORT_HANDLE: u16 = 0xffff_u16; use dozer_types::errors::internal::BoxedError; use dozer_types::geo::{Coord, Point}; use dozer_types::ordered_float::OrderedFloat;