(seq)
| 66 | |
| 67 | |
| 68 | def _batch(seq): |
| 69 | # XXX: Replace with itertools.batched |
| 70 | n = np.clip(int(len(seq) // (os.cpu_count() or 1)), 1, 300) |
| 71 | for i in range(0, len(seq), n): |
| 72 | yield seq[i:i + n] |
| 73 | |
| 74 | |
| 75 | def _data_period(index) -> Union[pd.Timedelta, Number]: |
no outgoing calls