diff --git a/app/server/modules/backups/backup-executor.ts b/app/server/modules/backups/backup-executor.ts index fa45a472..4aea9aa3 100644 --- a/app/server/modules/backups/backup-executor.ts +++ b/app/server/modules/backups/backup-executor.ts @@ -1,3 +1,4 @@ +import { Effect } from "effect"; import { restic } from "../../core/restic"; import type { BackupSchedule, Repository, Volume } from "../../db/schema"; import type { ResticBackupOutputDto, ResticBackupProgressDto } from "@zerobyte/core/restic"; @@ -55,12 +56,14 @@ export const backupExecutor = { const volumePath = getVolumePath(volume); const backupOptions = createBackupOptions(schedule, volumePath, signal); - const result = await restic.backup(repository.config, volumePath, { - ...backupOptions, - compressionMode: repository.compressionMode ?? "auto", - organizationId, - onProgress, - }); + const result = await Effect.runPromise( + restic.backup(repository.config, volumePath, { + ...backupOptions, + compressionMode: repository.compressionMode ?? "auto", + organizationId, + onProgress, + }), + ); return { status: "completed",