MessageGroupId should be included as a variable in kale.publisher about ndkale HOT 5 CLOSED

# Added msg_group_id for customization of id
def publish(self, task_class, task_id, payload,
                current_retry_num=None, delay_sec=None, msg_group_id='default'): 
        """Publish the given task type to the queue with the provided payload.

        :param obj task_class: class of the task that we are publishing.
        :param str task_id: unique identifying string for this task.
        :param dict payload: dictionary for the task payload.
        :param int current_retry_num: current task retry count. If 0, this is
            the first attempt to run the task.
        :param int delay_sec: time (in seconds) that a task should stay
                in the queue before being released to consumers.
        :param str msg_group_id: MessageGroupId Parameter for Content-based 
                Deduplication enabled queues
        :raises: TaskTooChubbyException: This task is outrageously chubby.
                The publisher of the task should handle this exception and
                determine how to proceed.def publish(self, task_class, task_id, payload,
        """

        if delay_sec is not None and delay_sec > settings.SQS_MAX_TASK_DELAY_SEC:
            raise exceptions.InvalidTaskDelayException(
                'Invalid task delay_sec (%d > %d).' % (
                    delay_sec, settings.SQS_MAX_TASK_DELAY_SEC))

        queue_class = utils.class_import_from_path(settings.QUEUE_CLASS)
        q_info = queue_info.QueueInfo(settings.QUEUE_CONFIG, self, queue_class)
        queue_obj = q_info.get_queue(task_class.queue)

        if task_class.time_limit >= queue_obj.visibility_timeout_sec:
            raise exceptions.InvalidTimeLimitTaskException(
                'Invalid task time limit: %d >= %d from %s' % (
                    task_class.time_limit, queue_obj.visibility_timeout_sec,
                    settings.QUEUE_CONFIG))

        sqs_queue = self._get_or_create_queue(queue_obj.name)

        kale_msg = message.KaleMessage(
            task_class=task_class,
            task_id=task_id,
            payload=payload,
            current_retry_num=current_retry_num)

        # Updated Code Block
        #######################################################
        params = { "MessageBody": kale_msg.encode() }
        print(sqs_queue.attributes)

        if bool(sqs_queue.attributes['ContentBasedDeduplication']):
            params['MessageGroupId']=msg_group_id
        
        if not bool(sqs_queue.attributes['FifoQueue']):
            params['DelaySeconds']=delay_sec or 1

        sqs_queue.send_message(**params)
         #######################################################

        logger.debug('Published task. Task id: %s; Task name: %s' % (
            task_id, '%s.%s' % (task_class.__module__, task_class.__name__)))