Merge pull request #58 from stackkit/master

Bugfix: task retries

Author: marickvantuil

src/CloudTasksJob.php

@@ -95,11 +95,4 @@ public function delete(): void
 
         $this->cloudTasksQueue->delete($this);
     }
-
-    public function fire(): void
-    {
-        $this->attempts++;
-
-        parent::fire();
-    }
 }

src/TaskHandler.php

@@ -95,7 +95,7 @@ private function handleTask(array $task): void
 
         $this->loadQueueRetryConfig($job);
 
-        $job->setAttempts((int) request()->header('X-CloudTasks-TaskExecutionCount'));
+        $job->setAttempts((int) request()->header('X-CloudTasks-TaskRetryCount'));
         $job->setMaxTries($this->retryConfig->getMaxAttempts());
 
         // If the job is being attempted again we also check if a
@@ -108,9 +108,18 @@ private function handleTask(array $task): void
                 throw new UnexpectedValueException('Expected task name to be a string.');
             }
 
-            $job->setRetryUntil(CloudTasksApi::getRetryUntilTimestamp($taskName));
+            $fullTaskName = $this->client->taskName(
+                $this->config['project'],
+                $this->config['location'],
+                $job->getQueue() ?: $this->config['queue'],
+                $taskName,
+            );
+
+            $job->setRetryUntil(CloudTasksApi::getRetryUntilTimestamp($fullTaskName));
         }
 
+        $job->setAttempts($job->attempts() + 1);
+
         app('queue.worker')->process($this->config['connection'], $job, new WorkerOptions());
     }
 

tests/TestCase.php

@@ -143,16 +143,16 @@ public function run(): void
                     app(TaskHandler::class)->handle($this->payload);
                 });
 
-                $taskExecutionCount = request()->header('X-CloudTasks-TaskExecutionCount', 0);
-                request()->headers->set('X-CloudTasks-TaskExecutionCount', $taskExecutionCount + 1);
+                $taskRetryCount = request()->header('X-CloudTasks-TaskRetryCount', 0);
+                request()->headers->set('X-CloudTasks-TaskRetryCount', $taskRetryCount + 1);
             }
 
             public function runWithoutExceptionHandler(): void
             {
                 app(TaskHandler::class)->handle($this->payload);
 
-                $taskExecutionCount = request()->header('X-CloudTasks-TaskExecutionCount', 0);
-                request()->headers->set('X-CloudTasks-TaskExecutionCount', $taskExecutionCount + 1);
+                $taskRetryCount = request()->header('X-CloudTasks-TaskRetryCount', 0);
+                request()->headers->set('X-CloudTasks-TaskRetryCount', $taskRetryCount + 1);
             }
         };
     }