Bugs in `syncPartitionQueues()` implementation ๐
Closed this issue ยท 0 comments
sudiptob2 commented
There are some minor bugs in the syncPartitionQueues()
implementation that cause yhs
to crash. Please refer to the following code snippet for details:
Incorrect Parameter on Line 104
Currently, partition.Name
is passed as a parameter, but it should be partition.ID
. Since we're now using IDs, the partition.ID
parameter may be unnecessary, allowing us to refactor the function as follows:
GetQueueInPartition(ctx context.Context, partitionID, queueID string) => GetQueueInPartition(ctx context.Context, queueID string)