diff options
| author | Bobby <[email protected]> | 2026-02-03 15:17:34 +0530 |
|---|---|---|
| committer | Bobby <[email protected]> | 2026-02-03 15:17:34 +0530 |
| commit | 7aa298f90fb17bc915f15a90180feb8434d596a0 (patch) | |
| tree | 084e93e769591cb47eb453ca2adf3e78646d4e73 /tasks/tasks.go | |
| parent | fb233706694e73774751f2481bf7b5df57b98fd9 (diff) | |
| download | metachan-7aa298f90fb17bc915f15a90180feb8434d596a0.tar.xz metachan-7aa298f90fb17bc915f15a90180feb8434d596a0.zip | |
Enhance episode ID generation and task management: include MAL ID and episode number for uniqueness, and update AnimeSync task to run weekly with last run tracking
Diffstat (limited to 'tasks/tasks.go')
| -rw-r--r-- | tasks/tasks.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/tasks/tasks.go b/tasks/tasks.go index ecf8d80..484a826 100644 --- a/tasks/tasks.go +++ b/tasks/tasks.go @@ -36,6 +36,12 @@ func init() { Level: logger.Error, Prefix: "TaskManager", }) + GlobalTaskManager.logTaskExecution("AnimeSync", "error", err.Error()) + } else { + // Update AnimeSync's LastRun after successful completion + animeSyncEndTime := time.Now() + GlobalTaskManager.UpdateTaskLastRun("AnimeSync", animeSyncEndTime) + GlobalTaskManager.logTaskExecution("AnimeSync", "success", "Task executed successfully") } }() return nil @@ -52,7 +58,7 @@ func init() { // Register AnimeSync task (triggered automatically after AnimeFetch completes) err = GlobalTaskManager.RegisterTask(types.Task{ Name: "AnimeSync", - Interval: 0, // No scheduled interval - runs after AnimeFetch + Interval: 7 * 24 * time.Hour, // Same interval as AnimeFetch Execute: AniSync, }) |
