Timer

Фреймворк дозволяє призупинити виконання workflow та продовжити його пізніше. Це стійкі timer: вони переживають перезапуски й збої та залишаються узгодженими із семантикою відтворення workflow. Це корисно для затримок, логіки повторних спроб чи тайм-аутів.

Для використання timer викличте timer($duration) усередині workflow:

use function Workflow\V2\timer;
use Workflow\V2\Workflow;

class MyWorkflow extends Workflow
{
    public function handle(): string
    {
        timer(30);

        return 'The workflow waited 30 seconds.';
    }
}

Поведінка timer:

• кожен timer() створює стійкий рядок timer та типізовані події історії TimerScheduled, TimerFired і, після заміщення, TimerCancelled
• відкладені timer виконуються через окреме завдання timer до відновлення завдання workflow
• timer(0) спрацьовує безпосередньо під час завдання workflow та не створює завдання timer
• шляхи відтворення й query вважають типізовану історію TimerScheduled, TimerFired та TimerCancelled авторитетним джерелом життєвого циклу timer. Тому звичайні timer залишаються заблокованими до надходження зафіксованої події спрацювання, а деталі обраного запуску можуть відновити з історії відкриті, спрацьовані чи скасовані очікування timer
• Waterline показує очікування timer у деталях запуску та даних панелі
• команди cancel() і terminate() на рівні рушія стійко заміщують відкриті очікування timer. Запізнілі завдання timer нічого не змінюють і не відкривають запуск повторно

Timer будь-якої тривалості працюють із кожним драйвером черг Laravel, включно з Amazon SQS. Рушій автоматично ділить довгі затримки на частини відповідно до межі драйвера для одного повідомлення.

sideEffect() доступний для знімків, безпечних для відтворення, наприклад випадковості чи одноразових вхідних даних розгалуження.

Читання детермінованого часу

У тілі workflow для поточного часу використовуйте Workflow::now() або Workflow\V2\now() замість допоміжної функції Laravel now() чи Carbon::now():

use function Workflow\V2\activity;
use function Workflow\V2\now;
use Workflow\V2\Workflow;

class DurationAwareWorkflow extends Workflow
{
    public function handle(string $name): array
    {
        $startedAt = Workflow::now();
        $greeting = activity(GreetingActivity::class, $name);
        $finishedAt = Workflow::now();

        return [
            'greeting' => $greeting,
            'took_ms' => $finishedAt->getTimestampMs() - $startedAt->getTimestampMs(),
        ];
    }
}

Workflow::now() просувається, коли виконавець відтворює події історії. Він повертає recorded_at останнього завершення activity, спрацювання timer, отримання signal, розв’язання умови чи завершення дочірнього workflow, яке спожило відтворення. До споживання будь-якої події він повертає started_at запуску. Поза Fiber workflow, наприклад в activity чи методі query, що делегує допоміжній функції поза workflow, він використовує реальний час now().

Використання Workflow::now() зберігає детермінованість workflow: два відтворення тієї самої історії повертають ті самі значення часу, навіть якщо між ними реальний час просунувся.