Fixed bug in JobManager in \TamerLib\Classes > JobManager > returnJob()
and \TamerLib\Classes > JobManager > returnException()
where if the "return_channel" is empty instead of null, the job would be returned to an empty channel instead of being dropped.
This commit is contained in:
parent
499a871ce5
commit
ba82426e32
3 changed files with 12 additions and 4 deletions
10
CHANGELOG.md
10
CHANGELOG.md
|
@ -5,7 +5,15 @@ All notable changes to this project will be documented in this file.
|
||||||
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
||||||
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
||||||
|
|
||||||
## [2.1.0] - 2023-07-7
|
## [2.1.1] - 2023-07-07
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
- Fixed bug in JobManager in `\TamerLib\Classes > JobManager > returnJob()` and `\TamerLib\Classes > JobManager > returnException()`
|
||||||
|
where if the "return_channel" is empty instead of null, the job would be returned to an empty channel instead of
|
||||||
|
being dropped.
|
||||||
|
|
||||||
|
|
||||||
|
## [2.1.0] - 2023-07-07
|
||||||
|
|
||||||
### Added
|
### Added
|
||||||
- Implemented `ausleep()` in for `TamerLib\Classes\ > JobManager` to allow TamerLib to monitor sub-processes and
|
- Implemented `ausleep()` in for `TamerLib\Classes\ > JobManager` to allow TamerLib to monitor sub-processes and
|
||||||
|
|
|
@ -22,7 +22,7 @@
|
||||||
"description": "TamerLib allows the execution of parallel tasks",
|
"description": "TamerLib allows the execution of parallel tasks",
|
||||||
"company": "Nosial",
|
"company": "Nosial",
|
||||||
"copyright": "Copyright (c) 2022-2023 Nosial, All Rights Reserved",
|
"copyright": "Copyright (c) 2022-2023 Nosial, All Rights Reserved",
|
||||||
"version": "2.1.0",
|
"version": "2.1.1",
|
||||||
"uuid": "a365e7d6-a1c0-11ed-b7c7-b9654ed9efa5"
|
"uuid": "a365e7d6-a1c0-11ed-b7c7-b9654ed9efa5"
|
||||||
},
|
},
|
||||||
"build": {
|
"build": {
|
||||||
|
|
|
@ -694,7 +694,7 @@
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @noinspection PhpUndefinedVariableInspection */
|
/** @noinspection PhpUndefinedVariableInspection */
|
||||||
if($return_channel === null)
|
if($return_channel === null || $return_channel === '')
|
||||||
{
|
{
|
||||||
Log::debug(Utilities::getName(), sprintf('No return channel set, deleting job %s', $job_id));
|
Log::debug(Utilities::getName(), sprintf('No return channel set, deleting job %s', $job_id));
|
||||||
$this->getClient()->del($job_id);
|
$this->getClient()->del($job_id);
|
||||||
|
@ -755,7 +755,7 @@
|
||||||
}
|
}
|
||||||
|
|
||||||
/** @noinspection PhpUndefinedVariableInspection */
|
/** @noinspection PhpUndefinedVariableInspection */
|
||||||
if($return_channel === null)
|
if($return_channel === null || $return_channel === '')
|
||||||
{
|
{
|
||||||
Log::debug(Utilities::getName(), sprintf('No return channel set, deleting job %s', $job_id));
|
Log::debug(Utilities::getName(), sprintf('No return channel set, deleting job %s', $job_id));
|
||||||
$this->getClient()->del($job_id);
|
$this->getClient()->del($job_id);
|
||||||
|
|
Loading…
Add table
Reference in a new issue