| @@ 100-111 (lines=12) @@ | ||
| 97 | * @param QueuedTask $run |
|
| 98 | * @param $response |
|
| 99 | */ |
|
| 100 | public function success(QueuedTask $run, $response) |
|
| 101 | { |
|
| 102 | if (!empty($response)) { |
|
| 103 | $run->setResult(print_r($response, true)); |
|
| 104 | } |
|
| 105 | ||
| 106 | $run->setStatus(QueuedTask::STATUS_DONE); |
|
| 107 | $run->setResolution(QueuedTask::RESOLUTION_SUCCESS); |
|
| 108 | $run->setFinished(new \DateTime()); |
|
| 109 | ||
| 110 | $this->doctrine->getManager()->flush(); |
|
| 111 | } |
|
| 112 | ||
| 113 | /** |
|
| 114 | * @param QueuedTask $run |
|
| @@ 117-128 (lines=12) @@ | ||
| 114 | * @param QueuedTask $run |
|
| 115 | * @param $response |
|
| 116 | */ |
|
| 117 | public function failure(QueuedTask $run, $response) |
|
| 118 | { |
|
| 119 | if (!empty($response)) { |
|
| 120 | $run->setResult(print_r($response, true)); |
|
| 121 | } |
|
| 122 | ||
| 123 | $run->setStatus(QueuedTask::STATUS_DONE); |
|
| 124 | $run->setResolution(QueuedTask::RESOLUTION_FAILURE); |
|
| 125 | $run->setFinished(new \DateTime()); |
|
| 126 | ||
| 127 | $this->doctrine->getManager()->flush(); |
|
| 128 | } |
|
| 129 | } |
|
| 130 | ||