cb919c5e5c151f87616850c056402beefd5f7ff6,streaming/python/runtime/transfer.py,DataReader,__init__,#DataReader#Any#Any#Any#,369

Before Change

            py_msg_ids, timer_interval, config_bytes, is_mock)

        self.__creation_status = {}
        for q, status in queues_creation_status.items():
            self.__creation_status[q] = ChannelCreationStatus(status)
        logger.info("create DataReader succeed, creation_status={}".format(
            self.__creation_status))

    def read(self, timeout_millis):

After Change

        ]
        creation_parameters = ChannelCreationParametersBuilder()
        creation_parameters.build_input_queue_parameters(from_actors)
        py_seq_ids = [0 for _ in range(len(input_channels))]
        py_msg_ids = [0 for _ in range(len(input_channels))]
        timer_interval = int(conf.get(Config.TIMER_INTERVAL_MS, -1))
        is_recreate = bool(conf.get(Config.IS_RECREATE, False))

Instances