@@ 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 |