改名
This commit is contained in:
@@ -193,6 +193,7 @@ abstract class Crontab implements PipeMessage
|
|||||||
*/
|
*/
|
||||||
public function execute(): void
|
public function execute(): void
|
||||||
{
|
{
|
||||||
|
defer(fn() => $this->afterExecute());
|
||||||
try {
|
try {
|
||||||
$redis = $this->application->getRedis();
|
$redis = $this->application->getRedis();
|
||||||
|
|
||||||
@@ -204,8 +205,6 @@ abstract class Crontab implements PipeMessage
|
|||||||
$redis->hDel(self::WAIT_END, $name_md5);
|
$redis->hDel(self::WAIT_END, $name_md5);
|
||||||
} catch (\Throwable $throwable) {
|
} catch (\Throwable $throwable) {
|
||||||
$this->application->addError($throwable, 'throwable');
|
$this->application->addError($throwable, 'throwable');
|
||||||
} finally {
|
|
||||||
$this->afterExecute();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user