(self, config: Dict, data_source_id: int, last_index_time: datetime = None)
| 103 | raise NotImplementedError |
| 104 | |
| 105 | def __init__(self, config: Dict, data_source_id: int, last_index_time: datetime = None) -> None: |
| 106 | self._raw_config = config |
| 107 | self._config: BaseDataSourceConfig = BaseDataSourceConfig(**self._raw_config) |
| 108 | self._data_source_id = data_source_id |
| 109 | |
| 110 | if last_index_time is None: |
| 111 | last_index_time = datetime(2012, 1, 1) |
| 112 | self._last_index_time = last_index_time |
| 113 | self._last_task_time = None |
| 114 | |
| 115 | def get_id(self): |
| 116 | return self._data_source_id |
nothing calls this directly
no test coverage detected