def _encode_send_job(self, job): json = self._encode_base_job(job) json.update({ 'subject': job.subject, 'messageId': job.message_id }) return json