public function markFailed(WorkPackage $task, $log)
    {
        if ($this->logWorkerOutputOnFailure) {
            $this->updateTaskLog($task, $log);
        }
        $this->updateTaskStatus($task, Task::STATUS_FAILED);
        $this->beanstalk->delete($task->getPheanstalkJob());
    }
public function markFailed(WorkPackage $task, $log)
    {
        if ($this->logWorkerOutputOnFailure) {
            $this->updateTaskLog($task, $log);
        }
        $this->updateTaskStatus($task, Task::STATUS_FAILED);
        $this->beanstalk->delete($task->getPheanstalkJob());
    }
public function markFailed ( WorkPackage $ task , $ log ) { if ( $ this -> logWorkerOutputOnFailure ) { $ this -> updateTaskLog ( $ task , $ log ) ; } $ this -> updateTaskStatus ( $ task , Task :: STATUS_FAILED ) ; $ this -> beanstalk -> delete ( $ task -> getPheanstalkJob ( ) ) ; }
Marks a job as failed and deletes it from the beanstalk tube

@param WorkPackage $task
@param string      $log
@throws TaskQueueServiceException
@return void
Marks a job as failed and deletes it from the beanstalk tube