Nosial/tamerlib
2
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions

Minor correction

Browse source
This commit is contained in:
Netkas 2023-06-16 01:47:59 -04:00
parent db47d0fc0e
commit f0ceb736d1
No known key found for this signature in database
GPG key ID: 5DAF58535614062B
1 changed files with 13 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/TamerLib/Classes/JobManager.php
View file

@ -605,7 +605,7 @@
return; return;
} }
Log::debug(Utilities::getName(), sprintf('Returning job %s (Return Channel: %s)', $job_id, $return_channel ?? 'n/a')); Log::debug(Utilities::getName(), sprintf('Returning job %s (Return Channel: %s)', $job_id, $return_channel));
$this->getClient()->hSet($job_id, 'return_value', serialize($return_value)); $this->getClient()->hSet($job_id, 'return_value', serialize($return_value));
$this->getClient()->hSet($job_id, 'status', JobStatus::FINISHED); $this->getClient()->hSet($job_id, 'status', JobStatus::FINISHED);
$this->getClient()->rPush($this->getClient()->hGet($job_id, 'return_channel'), $job_id); $this->getClient()->rPush($this->getClient()->hGet($job_id, 'return_channel'), $job_id);
@ -643,21 +643,22 @@
try try
{ {
if($this->getClient()->exists($job_id)) if(!$this->getClient()->exists($job_id))
{ {
if($this->getClient()->hGet($job_id, 'return_channel') === null) throw new JobNotFoundException(sprintf('Job %s does not exist on %s:%s', $job_id, $this->server_configuration->getHost(), $this->server_configuration->getPort()));
{ }
$this->getClient()->del($job_id);
return;
}
Log::debug(Utilities::getName(), sprintf('Returning exception for job %s', $job_id)); if($this->getClient()->hGet($job_id, 'return_channel') === null)
$this->getClient()->hSet($job_id, 'exception', serialize($throwable)); {
$this->getClient()->hSet($job_id, 'status', JobStatus::FAILED); $this->getClient()->del($job_id);
$this->getClient()->rPush($this->getClient()->hGet($job_id, 'return_channel'), $job_id);
Log::debug(Utilities::getName(), sprintf('Pushed job %s to return channel %s', $job_id, $this->getClient()->hGet($job_id, 'return_channel')));
return; return;
} }
Log::debug(Utilities::getName(), sprintf('Returning exception for job %s', $job_id));
$this->getClient()->hSet($job_id, 'exception', serialize($throwable));
$this->getClient()->hSet($job_id, 'status', JobStatus::FAILED);
$this->getClient()->rPush($this->getClient()->hGet($job_id, 'return_channel'), $job_id);
Log::debug(Utilities::getName(), sprintf('Pushed job %s to return channel %s', $job_id, $this->getClient()->hGet($job_id, 'return_channel')));
} }
catch(RedisException $e) catch(RedisException $e)
{ {