This commit is contained in:
Manav Rathi
2024-09-18 09:10:37 +05:30
parent 69a5795c86
commit 87f9537bb2
2 changed files with 9 additions and 11 deletions

View File

@@ -2,7 +2,7 @@ import { triggerFeatureFlagsFetchIfNeeded } from "@/new/photos/services/feature-
import {
isMLSupported,
mlStatusSync,
triggerMLSync,
mlSync,
wipClusterEnable,
} from "@/new/photos/services/ml";
import { syncCGroups } from "@/new/photos/services/ml/cgroups";
@@ -46,7 +46,7 @@ export const sync = async () => {
wipClusterEnable().then((enable) =>
enable ? syncCGroups().then(rereadCGroups) : undefined,
),
isMLSupported && mlSync(),
]);
triggerSearchDataSync();
if (isMLSupported) triggerMLSync();
};

View File

@@ -207,8 +207,8 @@ export const enableML = async () => {
setIsMLEnabledLocal(true);
_state.isMLEnabled = true;
setInterimScheduledStatus();
triggerStatusUpdate();
triggerMLSync();
// Trigger updates, but don't wait for them to finish.
void updateMLStatusSnapshot().then(mlSync);
};
/**
@@ -288,7 +288,7 @@ export const mlStatusSync = async () => {
};
/**
* Trigger a ML sync.
* Perform a ML sync.
*
* This is called during the global sync sequence, after files information have
* been synced with remote.
@@ -299,9 +299,7 @@ export const mlStatusSync = async () => {
* This will only have an effect if {@link mlStatusSync} has been called at
* least once prior to calling this in the sync sequence.
*/
export const triggerMLSync = () => void mlSync();
const mlSync = async () => {
export const mlSync = async () => {
if (_state.isMLEnabled) await worker().then((w) => w.sync());
};
@@ -514,12 +512,12 @@ export const mlStatusSnapshot = (): MLStatus | undefined => {
};
/**
* Trigger an asynchronous and unconditional update of the {@link MLStatus}
* snapshot.
* Trigger an asynchronous update of the {@link MLStatus} snapshot, and return
* without waiting for it to finish.
*/
const triggerStatusUpdate = () => void updateMLStatusSnapshot();
/** Unconditional update of the {@link MLStatus} snapshot. */
/** Unconditionally update of the {@link MLStatus} snapshot. */
const updateMLStatusSnapshot = async () =>
setMLStatusSnapshot(await getMLStatus());