client.py 文件源码

def _base_send_request(self, request_id, meta, job_request):
        with self.metrics.timer('client.send.excluding_middleware'):
            if isinstance(job_request, JobRequest):
                job_request = attr.asdict(job_request, dict_factory=UnicodeKeysDict)
            meta['__request_serialized__'] = True
            self.transport.send_request_message(
                request_id,
                meta,
                self.serializer.dict_to_blob(job_request),
            )
            # meta['__request_serialized__'] = False
            # self.transport.send_request_message(request_id, meta, job_request)