0ct0pu5/ente
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Flatten

Browse source
This commit is contained in:
Manav Rathi 2024-05-15 10:08:28 +05:30
parent 34a3a8700e
commit 8eb3170067
No known key found for this signature in database
1 changed files with 5 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
web/apps/photos/src/services/machineLearning/mlWorkManager.ts
View file

@ -25,19 +25,20 @@ export interface JobConfig {
backoffMultiplier: number;
}
export interface JobResult {
export interface MLSyncJobResult {
shouldBackoff: boolean;
mlSyncResult: MLSyncResult;
}
export class SimpleJob<R extends JobResult> {
export class MLSyncJob {
private config: JobConfig;
private runCallback: () => Promise<R>;
private runCallback: () => Promise<MLSyncJobResult>;
private state: JobState;
private stopped: boolean;
private intervalSec: number;
private nextTimeoutId: ReturnType<typeof setTimeout>;
constructor(config: JobConfig, runCallback: () => Promise<R>) {
constructor(config: JobConfig, runCallback: () => Promise<MLSyncJobResult>) {
this.config = config;
this.runCallback = runCallback;
this.state = "NotScheduled";
@ -109,12 +110,6 @@ export class SimpleJob<R extends JobResult> {
}
}
export interface MLSyncJobResult extends JobResult {
mlSyncResult: MLSyncResult;
}
export class MLSyncJob extends SimpleJob<MLSyncJobResult> {}
class MLWorkManager {
private mlSyncJob: MLSyncJob;
private syncJobWorker: ComlinkWorker<typeof DedicatedMLWorker>;