diff --git a/src/audio/copier/copier_generic.c b/src/audio/copier/copier_generic.c
index da1ca4dbf942..f51b417451b6 100644
--- a/src/audio/copier/copier_generic.c
+++ b/src/audio/copier/copier_generic.c
@@ -328,7 +328,7 @@ void copier_update_params(struct copier_data *cd, struct comp_dev *dev,
 	/* update each sink format */
 	comp_dev_for_each_consumer(dev, sink) {
 		int j;
-		j = IPC4_SINK_QUEUE_ID(buf_get_id(sink));
+		j = IPC4_SRC_QUEUE_ID(buf_get_id(sink));
 
 		ipc4_update_buffer_format(sink, &cd->out_fmt[j]);
 	}
diff --git a/src/audio/dai-zephyr.c b/src/audio/dai-zephyr.c
index ef1abb48cc31..d24f3c2024ba 100644
--- a/src/audio/dai-zephyr.c
+++ b/src/audio/dai-zephyr.c
@@ -362,7 +362,7 @@ dai_dma_cb(struct dai_data *dd, struct comp_dev *dev, uint32_t bytes,
 
 				sink_dev = comp_buffer_get_sink_component(sink);
 
-				j = IPC4_SINK_QUEUE_ID(buf_get_id(sink));
+				j = IPC4_SRC_QUEUE_ID(buf_get_id(sink));
 
 				if (j >= IPC4_COPIER_MODULE_OUTPUT_PINS_COUNT) {
 					comp_err(dev, "Sink queue ID: %d >= max output pin count: %d\n",
diff --git a/src/probe/probe.c b/src/probe/probe.c
index 339935993ef1..b88cd747de18 100644
--- a/src/probe/probe.c
+++ b/src/probe/probe.c
@@ -1102,7 +1102,7 @@ static struct comp_buffer *ipc4_get_buffer(struct ipc_comp_dev *dev, probe_point
 	switch (probe_point.fields.type) {
 	case PROBE_TYPE_INPUT:
 		comp_dev_for_each_producer(dev->cd, buf) {
-			queue_id = IPC4_SRC_QUEUE_ID(buf_get_id(buf));
+			queue_id = IPC4_SINK_QUEUE_ID(buf_get_id(buf));
 
 			if (queue_id == probe_point.fields.index)
 				return buf;
@@ -1110,7 +1110,7 @@ static struct comp_buffer *ipc4_get_buffer(struct ipc_comp_dev *dev, probe_point
 		break;
 	case PROBE_TYPE_OUTPUT:
 		comp_dev_for_each_consumer(dev->cd, buf) {
-			queue_id = IPC4_SINK_QUEUE_ID(buf_get_id(buf));
+			queue_id = IPC4_SRC_QUEUE_ID(buf_get_id(buf));
 
 			if (queue_id == probe_point.fields.index)
 				return buf;
@@ -1581,14 +1581,14 @@ static int probe_get_available_points(struct processing_module *mod,
 
 		id.fields.type = PROBE_TYPE_INPUT;
 		comp_dev_for_each_producer(icd->cd, buf) {
-			id.fields.index = IPC4_SRC_QUEUE_ID(buf_get_id(buf));
+			id.fields.index = IPC4_SINK_QUEUE_ID(buf_get_id(buf));
 			if (probe_add_point_info_params(info, id, i, max_size))
 				return 0;
 			i++;
 		}
 		id.fields.type = PROBE_TYPE_OUTPUT;
 		comp_dev_for_each_consumer(icd->cd, buf) {
-			id.fields.index = IPC4_SINK_QUEUE_ID(buf_get_id(buf));
+			id.fields.index = IPC4_SRC_QUEUE_ID(buf_get_id(buf));
 			if (probe_add_point_info_params(info, id, i, max_size))
 				return 0;
 			i++;