Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 00:49:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix: sync updated schedules

Browse source
This commit is contained in:
loks0n 2025-12-17 14:19:04 +00:00
parent 8d94b6585e
commit ee8e7333d8
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/Appwrite/Platform/Tasks/ScheduleBase.php
View file

@ -123,6 +123,7 @@ abstract class ScheduleBase extends Action
$total = 0;
$latestDocument = null;
$updatedProjectIds = []; // Track project IDs from updated/new schedules
$updatedSequences = []; // Track sequences that need project/resource loading
while ($sum === $limit) {
$paginationQueries = [Query::limit($limit)];
@ -186,8 +187,9 @@ abstract class ScheduleBase extends Action
Console::info("Updating: {$candidate['resourceType']}::{$candidate['resourceId']}");
$this->schedules[$schedule->getSequence()] = $candidate;
// Track projectId for updated/new schedules
// Track projectId and sequence for updated/new schedules
$updatedProjectIds[] = $candidate['projectId'];
$updatedSequences[] = $schedule->getSequence();
}
}
@ -239,7 +241,13 @@ abstract class ScheduleBase extends Action
Console::success("No new projects to load (using " . count($map) . " cached projects)");
}
foreach ($this->schedules as $sequence => $schedule) {
// Only process updated/new schedules, not all schedules
foreach ($updatedSequences as $sequence) {
$schedule = $this->schedules[$sequence] ?? null;
if ($schedule === null) {
continue;
}
$project = $map[$schedule['projectId']] ?? null;
if ($project === null || $project->isEmpty()) {