改名
This commit is contained in:
@@ -201,7 +201,7 @@ 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'], ...$this->params);
|
call_user_func([$this, 'process']);
|
||||||
$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');
|
||||||
@@ -215,7 +215,6 @@ abstract class Crontab implements PipeMessage
|
|||||||
public function afterExecute()
|
public function afterExecute()
|
||||||
{
|
{
|
||||||
$aot = $this->isRecover();
|
$aot = $this->isRecover();
|
||||||
var_dump($aot);
|
|
||||||
if ($aot !== 999) {
|
if ($aot !== 999) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user