workflows
Create async background tasks (workflows) using SQS or Hatchet. Use when building queue jobs, background processing, or async tasks.
Installation
Pick a client and clone the repository into its skills directory.
Installation
About this skill
Create async background tasks (workflows) using SQS or Hatchet. Use when building queue jobs, background processing, or async tasks.
How to use
Dodaj nazwę zadania do enum JobName w pliku server/src/queue/JobName.ts — każde nowe workflow potrzebuje unikalnego identyfikatora.
Zdefiniuj typ payload'u dla swojego workflow w server/src/queue/workflows.ts — określ pola, które będą przesyłane (np. orgId, customerId, env).
Zarejestruj workflow w workflowRegistry, wskazując nazwę zadania i runner (SQS dla prostych zadań lub Hatchet dla złożonych) — dodaj też funkcję trigger do obiektu workflows.
Utwórz handler dla wybranego runnera — dla SQS sprawdź dokumentację w references/SQS.md, dla Hatchet w references/HATCHET.md.
Wyzwól workflow z kodu, importując funkcję trigger z @/queue/workflows.js i przekazując payload — opcjonalnie dodaj opóźnienie za pomocą parametru delayMs.
Skonfiguruj routing wiadomości SQS w pliku server/src/queue/initWorkers.ts, aby system wiedział, jak obsługiwać przychodzące zadania.