Revert "worker: Graceful shutdown on SIGTERM"

This commit is contained in:
Steven Nguyen
2025-06-20 18:40:04 -07:00
committed by GitHub
parent fd952f20d3
commit 6d55299836
33 changed files with 34 additions and 43 deletions
+2 -11
View File
@@ -18,9 +18,7 @@ use Appwrite\Event\StatsUsage;
use Appwrite\Event\Webhook; use Appwrite\Event\Webhook;
use Appwrite\Platform\Appwrite; use Appwrite\Platform\Appwrite;
use Executor\Executor; use Executor\Executor;
use Swoole\Process;
use Swoole\Runtime; use Swoole\Runtime;
use Swoole\Timer;
use Utopia\Abuse\Adapters\TimeLimit\Redis as TimeLimitRedis; use Utopia\Abuse\Adapters\TimeLimit\Redis as TimeLimitRedis;
use Utopia\Cache\Adapter\Pool as CachePool; use Utopia\Cache\Adapter\Pool as CachePool;
use Utopia\Cache\Adapter\Sharding; use Utopia\Cache\Adapter\Sharding;
@@ -484,15 +482,8 @@ $worker
}); });
$worker->workerStart() $worker->workerStart()
->action(function () use ($worker, $workerName) { ->action(function () use ($workerName) {
Console::info("Worker $workerName started"); Console::info("Worker $workerName started");
Process::signal(SIGTERM, function () use ($worker, $workerName) {
Console::info("Stopping worker $workerName.");
$worker->stop();
Timer::clearAll();
});
}); });
$worker->start(); $worker->start();
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php doctor $@ php /usr/src/code/app/cli.php doctor $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php install $@ php /usr/src/code/app/cli.php install $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php maintenance $@ php /usr/src/code/app/cli.php maintenance $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php migrate $@ php /usr/src/code/app/cli.php migrate $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php queue-count --type=failed $@ php /usr/src/code/app/cli.php queue-count --type=failed $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php queue-count --type=processing $@ php /usr/src/code/app/cli.php queue-count --type=processing $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php queue-count --type=success $@ php /usr/src/code/app/cli.php queue-count --type=success $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php queue-retry $@ php /usr/src/code/app/cli.php queue-retry $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/realtime.php $@ php /usr/src/code/app/realtime.php $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php schedule-executions $@ php /usr/src/code/app/cli.php schedule-executions $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php schedule-functions $@ php /usr/src/code/app/cli.php schedule-functions $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php schedule-messages $@ php /usr/src/code/app/cli.php schedule-messages $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php screenshot $@ php /usr/src/code/app/cli.php screenshot $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php sdks $@ php /usr/src/code/app/cli.php sdks $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php specs $@ php /usr/src/code/app/cli.php specs $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php ssl $@ php /usr/src/code/app/cli.php ssl $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php stats-resources $@ php /usr/src/code/app/cli.php stats-resources $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec /usr/src/code/vendor/bin/phpunit --configuration /usr/src/code/phpunit.xml $@ /usr/src/code/vendor/bin/phpunit --configuration /usr/src/code/phpunit.xml $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php upgrade $@ php /usr/src/code/app/cli.php upgrade $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/cli.php vars $@ php /usr/src/code/app/cli.php vars $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php audits $@ php /usr/src/code/app/worker.php audits $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php builds $@ php /usr/src/code/app/worker.php builds $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php certificates $@ php /usr/src/code/app/worker.php certificates $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php databases $@ php /usr/src/code/app/worker.php databases $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php deletes $@ php /usr/src/code/app/worker.php deletes $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php functions $@ php /usr/src/code/app/worker.php functions $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php mails $@ php /usr/src/code/app/worker.php mails $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php messaging $@ php /usr/src/code/app/worker.php messaging $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php migrations $@ php /usr/src/code/app/worker.php migrations $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php stats-resources $@ php /usr/src/code/app/worker.php stats-resources $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php stats-usage $@ php /usr/src/code/app/worker.php stats-usage $@
+1 -1
View File
@@ -1,3 +1,3 @@
#!/bin/sh #!/bin/sh
exec php /usr/src/code/app/worker.php webhooks $@ php /usr/src/code/app/worker.php webhooks $@