Skip to content

Commit 7767f30

Browse files
committed
Fix getRetryUntilTimestamp not working due to incomplete task name
1 parent 19c7267 commit 7767f30

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

src/TaskHandler.php

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,14 @@ private function handleTask(array $task): void
108108
throw new UnexpectedValueException('Expected task name to be a string.');
109109
}
110110

111-
$job->setRetryUntil(CloudTasksApi::getRetryUntilTimestamp($taskName));
111+
$fullTaskName = $this->client->taskName(
112+
$this->config['project'],
113+
$this->config['location'],
114+
$job->getQueue() ?: $this->config['queue'],
115+
$taskName,
116+
);
117+
118+
$job->setRetryUntil(CloudTasksApi::getRetryUntilTimestamp($fullTaskName));
112119
}
113120

114121
app('queue.worker')->process($this->config['connection'], $job, new WorkerOptions());

0 commit comments

Comments
 (0)