(self, instruments, start_time=None, end_time=None, freq="day", as_list=False)
| 996 | self.conn = conn |
| 997 | |
| 998 | def list_instruments(self, instruments, start_time=None, end_time=None, freq="day", as_list=False): |
| 999 | def inst_msg_proc_func(response_content): |
| 1000 | if isinstance(response_content, dict): |
| 1001 | instrument = { |
| 1002 | i: [(pd.Timestamp(s), pd.Timestamp(e)) for s, e in t] for i, t in response_content.items() |
| 1003 | } |
| 1004 | else: |
| 1005 | instrument = response_content |
| 1006 | return instrument |
| 1007 | |
| 1008 | self.conn.send_request( |
| 1009 | request_type="instrument", |
| 1010 | request_content={ |
| 1011 | "instruments": instruments, |
| 1012 | "start_time": str(start_time), |
| 1013 | "end_time": str(end_time), |
| 1014 | "freq": freq, |
| 1015 | "as_list": as_list, |
| 1016 | }, |
| 1017 | msg_queue=self.queue, |
| 1018 | msg_proc_func=inst_msg_proc_func, |
| 1019 | ) |
| 1020 | result = self.queue.get(timeout=C["timeout"]) |
| 1021 | if isinstance(result, Exception): |
| 1022 | raise result |
| 1023 | get_module_logger("data").debug("get result") |
| 1024 | return result |
| 1025 | |
| 1026 | |
| 1027 | class ClientDatasetProvider(DatasetProvider): |
nothing calls this directly
no test coverage detected