as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-07-23 18:12:46 +08:00
parent cfa2d8f8fb
commit 0b846865c9
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Crontab/Crontab.php
+4 -2
View File
@@ -202,6 +202,9 @@ abstract class Crontab implements PipeMessage
$redis->hSet(self::WAIT_END, $name_md5, static::getSerialize($this)); $redis->hSet(self::WAIT_END, $name_md5, static::getSerialize($this));
call_user_func([$this, 'process']); call_user_func([$this, 'process']);
$this->execute_number += 1;
$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');
@@ -214,8 +217,7 @@ abstract class Crontab implements PipeMessage
*/ */
public function afterExecute() public function afterExecute()
{ {
$aot = $this->isRecover(); if ($this->isRecover() !== 999) {
if ($aot !== 999) {
return; return;
} }
$redis = $this->application->getRedis(); $redis = $this->application->getRedis();