dave/coolify
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Add scheduled task for database cleanup if not in cloud environment

Browse Source
This commit is contained in:
Andras Bacsai
2024-03-04 12:17:33 +01:00
parent 65fcaa17d9
commit 99fe076b5a
1 changed files with 29 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
app/Console/Kernel.php
View File

@@ -47,6 +47,10 @@ class Kernel extends ConsoleKernel
$this->check_resources($schedule); $this->check_resources($schedule);
$this->pull_helper_image($schedule); $this->pull_helper_image($schedule);
$this->check_scheduled_tasks($schedule); $this->check_scheduled_tasks($schedule);
if (!isCloud()) {
$schedule->command('cleanup:database --yes')->daily();
}
} }
} }
private function pull_helper_image($schedule) private function pull_helper_image($schedule)
@@ -68,35 +72,35 @@ class Kernel extends ConsoleKernel
$containerServers = $servers->where('settings.is_swarm_worker', false)->where('settings.is_build_server', false); $containerServers = $servers->where('settings.is_swarm_worker', false)->where('settings.is_build_server', false);
} }
foreach ($containerServers as $server) { foreach ($containerServers as $server) {
$schedule->job(new ContainerStatusJob($server))->everyMinute()->onOneServer(); // $schedule->job(new ContainerStatusJob($server))->everyMinute()->onOneServer();
// $schedule $schedule
// ->call(function () use ($server) { ->call(function () use ($server) {
// $randomSeconds = rand(1, 40); $randomSeconds = rand(1, 40);
// $job = new ContainerStatusJob($server); $job = new ContainerStatusJob($server);
// $job->delay($randomSeconds); $job->delay($randomSeconds);
// ray('dispatching container status job in ' . $randomSeconds . ' seconds'); ray('dispatching container status job in ' . $randomSeconds . ' seconds');
// dispatch($job); dispatch($job);
// })->name('container-status-' . $server->id)->everyMinute()->onOneServer(); })->name('container-status-' . $server->id)->everyMinute()->onOneServer();
if ($server->isLogDrainEnabled()) { if ($server->isLogDrainEnabled()) {
$schedule->job(new CheckLogDrainContainerJob($server))->everyMinute()->onOneServer(); // $schedule->job(new CheckLogDrainContainerJob($server))->everyMinute()->onOneServer();
// $schedule $schedule
// ->call(function () use ($server) { ->call(function () use ($server) {
// $randomSeconds = rand(1, 40); $randomSeconds = rand(1, 40);
// $job = new CheckLogDrainContainerJob($server); $job = new CheckLogDrainContainerJob($server);
// $job->delay($randomSeconds); $job->delay($randomSeconds);
// dispatch($job); dispatch($job);
// })->name('log-drain-container-check-' . $server->id)->everyMinute()->onOneServer(); })->name('log-drain-container-check-' . $server->id)->everyMinute()->onOneServer();
} }
} }
foreach ($servers as $server) { foreach ($servers as $server) {
$schedule->job(new ServerStatusJob($server))->everyMinute()->onOneServer(); // $schedule->job(new ServerStatusJob($server))->everyMinute()->onOneServer();
// $schedule $schedule
// ->call(function () use ($server) { ->call(function () use ($server) {
// $randomSeconds = rand(1, 40); $randomSeconds = rand(1, 40);
// $job = new ServerStatusJob($server); $job = new ServerStatusJob($server);
// $job->delay($randomSeconds); $job->delay($randomSeconds);
// dispatch($job); dispatch($job);
// })->name('server-status-job-' . $server->id)->everyMinute()->onOneServer(); })->name('server-status-job-' . $server->id)->everyMinute()->onOneServer();
} }
} }
private function instance_auto_update($schedule) private function instance_auto_update($schedule)