(sessionId: string)
| 475 | } |
| 476 | |
| 477 | private markProgressDone(sessionId: string): void { |
| 478 | const p = this.progressMap.get(sessionId) |
| 479 | if (p) { |
| 480 | p.done = true |
| 481 | setTimeout(() => this.progressMap.delete(sessionId), 5000) |
| 482 | } |
| 483 | } |
| 484 | |
| 485 | async pullAllSessions(ds: DataSource): Promise<void> { |
| 486 | if (this.pullingSourceIds.has(ds.id)) { |
no test coverage detected