opengnsys
/
ogcore
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refs #2613. Captured busy client status
testing/ogcore-api/pipeline/head There was a failure building this commit Details

pull/47/head
Manuel Aranda Rosales 2025-08-25 12:29:28 +02:00
parent 17bb13393f
commit 8a8f67b776
1 changed files with 22 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/Controller/OgAgent/RunScriptAction.php
View File

@ -47,6 +47,10 @@ class RunScriptAction extends AbstractOgAgentController
$data = $this->buildRequestData($client, $input->script);
$response = $this->executeScript($client, $data);
if (isset($response['code']) && $response['code'] === 409) {
continue;
}
if ($this->isErrorResponse($response)) {
$this->handleError($client, $input, $response);
continue;
@ -98,7 +102,7 @@ class RunScriptAction extends AbstractOgAgentController
private function executeScript(Client $client, array $data): array
{
return $this->createRequest(
$response = $this->createRequest(
method: 'POST',
url: 'https://'.$client->getIp().':8000/opengnsys/EjecutarScript',
params: [
@ -106,6 +110,23 @@ class RunScriptAction extends AbstractOgAgentController
],
token: $client->getToken(),
);
if (isset($response['code']) && $response['code'] === 409) {
$this->createService->__invoke(
$client,
CommandTypes::RUN_SCRIPT,
TraceStatus::BUSY,
null,
['script' => $data['script'] ?? $data['scp'] ?? ''],
'Some job is already running, refusing to launch another one'
);
$this->logger->info('Trace created as busy due to 409 response', [
'client_ip' => $client->getIp()
]);
}
return $response;
}
private function isErrorResponse(array $response): bool