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

feat: retry execution logic

Browse source
This commit is contained in:
Christy Jacob 2022-02-17 20:49:18 +04:00
parent 1d7a2cfc71
commit 44c1154a42
1 changed files with 45 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
src/Executor/Executor.php
View file

@ -35,15 +35,14 @@ class Executor
string $deploymentId,
string $projectId,
string $source,
array $vars,
string $runtime,
string $baseImage,
array $commands
array $vars = [],
array $commands = []
) {
$route = "/runtimes";
$headers = [
'content-type' => 'application/json',
'x-appwrite-project' => $projectId,
'x-appwrite-executor-key' => App::getEnv('_APP_EXECUTOR_SECRET', '')
];
$params = [
@ -72,7 +71,6 @@ class Executor
$route = "/runtimes/$runtimeId";
$headers = [
'content-type' => 'application/json',
'x-appwrite-project' => $projectId,
'x-appwrite-executor-key' => App::getEnv('_APP_EXECUTOR_SECRET', '')
];
@ -99,12 +97,23 @@ class Executor
string $runtime,
string $baseImage,
$timeout
)
{
) {
// - 1st request
// - POST /execution
// - 404 - runtime not found
// - POST /runtimes - 200
// - POST /execution
// - 2nd request
// - POST /execution
// - 425 - runtime is not ready
// - Retries x 3 + 100ms wait
// - POST /execution
// - if failes anyway - throw and 4xx/5xx error
$route = "/execution";
$headers = [
'content-type' => 'application/json',
'x-appwrite-project' => $projectId,
'x-appwrite-executor-key' => App::getEnv('_APP_EXECUTOR_SECRET', '')
];
$params = [
@ -119,11 +128,37 @@ class Executor
];
$response = $this->call(self::METHOD_POST, $route, $headers, $params, true, 30);
$status = $response['headers']['status-code'];
if ($status >= 400) {
throw new \Exception($response['body']['message'], $status);
}
switch ($status) {
case 404:
$response = $this->createRuntime($functionId, $deploymentId, $projectId, $path, $runtime, $baseImage, $vars);
/** Try to create the execution once more */
$response = $this->call(self::METHOD_POST, $route, $headers, $params, true, 30);
$status = $response['headers']['status-code'];
if ($status >= 400) {
throw new \Exception($response['body']['message'], $status);
}
break;
case 425:
for ($i = 0; $i < 3; $i++) {
sleep(1);
$response = $this->call(self::METHOD_POST, $route, $headers, $params, true, 30);
$status = $response['headers']['status-code'];
if ($status < 400) {
break;
}
if ($status !== 425) {
throw new Exception($response['body']['message'], $status);
}
}
throw new Exception($response['body']['message'], 503);
default:
throw new \Exception($response['body']['message'], $status);
}
}
return $response['body'];
}