1 
2Οι περισσότερες εφαρμογές παραγωγής χρειάζονται εργασία που δεν χωράει στον κύκλο request/response: αποστολή email, επεξεργασία uploads, εκτέλεση pipelines AI, συγχρονισμός δεδομένων τρίτων, δημιουργία αναφορών. Η παραδοσιακή απάντηση είναι μια ουρά (Redis, SQS, RabbitMQ), ένας στόλος workers, ένας scheduler και ένας εύθραυστος σωρός κώδικα συγκόλλησης που σπάει σε κάθε deploy.
3 
4[Trigger.dev](https://trigger.dev) συμπυκνώνει αυτό το stack σε ένα μόνο TypeScript SDK. Γράφετε συναρτήσεις, τις καλείτε από οπουδήποτε και η πλατφόρμα χειρίζεται queueing, retries, observability, scheduling και ανθεκτική εκτέλεση. Τα tasks τρέχουν όσο χρειάζεται - χωρίς timeout serverless 10 δευτερολέπτων, χωρίς χαμένη εργασία στα redeploys.
5 
6## Γιατί Trigger.dev
7 
8Η αλλαγή το 2026 είναι η ανθεκτική εκτέλεση. Οι ροές εργασίας πρέπει να επιβιώνουν από επανεκκινήσεις, crashes, deploys και rate limits. Πρέπει επίσης να streamάρουν την πρόοδο στο UI σε πραγματικό χρόνο και να σταματούν για εισαγωγή ανθρώπου. Το Trigger.dev ξαναχτίστηκε γύρω από αυτές τις απαιτήσεις με την έκδοση 3 και συνεχίζει να επεκτείνει την επιφάνεια υποδομής AI.
9 
10```mermaid
11graph LR
12    App[Η εφαρμογή σας] -->|trigger| API[Trigger.dev API]
13    API --> Queue[Ανθεκτική Queue]
14    Queue --> Worker[Worker Container]
15    Worker -->|run task| Task[Κώδικας Task σας]
16    Task -->|metadata| Realtime[Realtime Stream]
17    Realtime --> UI[React UI]
18    Worker --> Storage[Run State Store]
19```
20 
21Το μοντέλο είναι απλό: ορίζετε tasks ως exports, το SDK τα παίρνει, η πλατφόρμα τα προγραμματίζει και τα τρέχει σε απομονωμένα containers και η κατάσταση run διατηρείται ώστε να μπορείτε να συνεχίσετε, να επαναλάβετε και να παρακολουθήσετε.
22 
23## Ξεκινώντας
24 
25### Αρχικοποίηση έργου
26 
27```bash
28npx trigger.dev@latest login
29npx trigger.dev@latest init
30```
31 
32Αυτό δημιουργεί ένα αρχείο `trigger.config.ts` και έναν κατάλογο `trigger/` με tasks παραδειγμάτων. Το αρχείο config είναι η πηγή αλήθειας για το έργο σας: ποιοι κατάλογοι περιέχουν tasks, ρυθμίσεις build, lifecycle hooks και επιλογές runtime.
33 
34```typescript
35// trigger.config.ts
36import { defineConfig } from "@trigger.dev/sdk";
37 
38export default defineConfig({
39  project: "proj_abc123",
40  runtime: "node",
41  logLevel: "log",
42  maxDuration: 3600,
43  retries: {
44    enabledInDev: true,
45    default: {
46      maxAttempts: 3,
47      factor: 2,
48      minTimeoutInMs: 1000,
49      maxTimeoutInMs: 30_000,
50    },
51  },
52  dirs: ["./trigger"],
53});
54```
55 
56### Εκτέλεση tasks τοπικά
57 
58```bash
59npx trigger.dev@latest dev
60```
61 
62Ο dev server συνδέεται με το cloud, καταχωρεί τα tasks σας και κάνει stream τα runs μέσω του τοπικού σας κώδικα. Βάζετε breakpoints στον editor σας και τα χτυπάτε σε πραγματικά triggers - το ίδιο loop που θα χρησιμοποιούσατε σε οποιοδήποτε κανονικό έργο Node.js.
63 
64## Ορισμός Task
65 
66Ένα task είναι ένα αντικείμενο που εξάγεται με ένα μοναδικό `id` και μια συνάρτηση `run`. Το SDK επιθεωρεί τα exports σε όλο το `dirs` και τα καταχωρεί αυτόματα.
67 
68```typescript
69// trigger/send-welcome-email.ts
70import { task } from "@trigger.dev/sdk";
71import { Resend } from "resend";
72 
73const resend = new Resend(process.env.RESEND_API_KEY);
74 
75export const sendWelcomeEmail = task({
76  id: "send-welcome-email",
77  retry: {
78    maxAttempts: 5,
79    factor: 1.8,
80    minTimeoutInMs: 500,
81    maxTimeoutInMs: 30_000,
82  },
83  run: async (payload: { email: string; name: string }) => {
84    const { data, error } = await resend.emails.send({
85      from: "hello@spinny.dev",
86      to: payload.email,
87      subject: `Welcome, ${payload.name}`,
88      html: `<p>Glad you are here, ${payload.name}.</p>`,
89    });
90 
91    if (error) throw error;
92    return { messageId: data?.id };
93  },
94});
95```
96 
97Τρία πράγματα να σημειώσετε:
98 
991. **Κανένα timeout στο σώμα run.** Η πλατφόρμα διαχειρίζεται τον χρόνο εκτέλεσης μέσω `maxDuration` στο config, όχι στο runtime.
1002. **Τα throws είναι retries.** Το SDK πιάνει εξαιρέσεις και τρέχει ξανά με exponential backoff σύμφωνα με την πολιτική `retry`.
1013. **Η τιμή επιστροφής διατηρείται.** Άλλα tasks και το frontend σας μπορούν να διαβάζουν `run.output` από οπουδήποτε.
102 
103## Triggering Tasks
104 
105Καλείτε ένα task από το backend σας, τις διαδρομές API ή ένα άλλο task.
106 
107```typescript
108import { sendWelcomeEmail } from "@/trigger/send-welcome-email";
109 
110const handle = await sendWelcomeEmail.trigger(
111  { email: "user@example.com", name: "Alex" },
112  {
113    idempotencyKey: `welcome-${userId}`,
114    concurrencyKey: `tenant-${tenantId}`,
115    queue: { name: "emails", concurrencyLimit: 50 },
116    delay: "30s",
117    ttl: "10m",
118  }
119);
120 
121console.log(handle.id); // run_xyz - χρησιμοποιήστε το για παρακολούθηση ή εμφάνιση προόδου
122```
123 
124Οι επιλογές ξεκλειδώνουν πολλή συμπεριφορά σε μία κλήση:
125 
126- **`idempotencyKey`** - αν ένα run με το ίδιο κλειδί υπάρχει ήδη, το SDK επιστρέφει το υπάρχον handle αντί να διπλασιάσει την εργασία.
127- **`concurrencyKey`** - σειριοποιεί τα runs που μοιράζονται το κλειδί ώστε να μην ξεπερνάτε ένα per-tenant rate limit.
128- **`queue.concurrencyLimit`** - παγκόσμιο cap για την ουρά σε όλα τα κλειδιά.
129- **`delay`** - προγραμματίζει το run για μελλοντικό χρόνο.
130- **`ttl`** - αν το run δεν έχει ξεκινήσει μέχρι τότε, λήγει αυτόματα.
131 
132### Batch trigger
133 
134Για fan-out workloads, το `batchTrigger` δέχεται έως 500 items ανά κλήση και δημιουργεί ένα run ανά item.
135 
136```typescript
137await sendWelcomeEmail.batchTrigger(
138  newUsers.map((u) => ({
139    payload: { email: u.email, name: u.name },
140    options: { idempotencyKey: `welcome-${u.id}` },
141  }))
142);
143```
144 
145## Προγραμματισμένα Tasks
146 
147Τα cron jobs γίνονται δηλώσεις πρώτης τάξης. Το ίδιο το schedule είναι ένα ξεχωριστό αντικείμενο που μπορείτε να επισυνάψετε σε ένα task πολλές φορές.
148 
149```typescript
150// trigger/daily-digest.ts
151import { schedules } from "@trigger.dev/sdk";
152 
153export const dailyDigest = schedules.task({
154  id: "daily-digest",
155  cron: "0 9 * * *",
156  run: async (payload) => {
157    console.log("Scheduled at:", payload.timestamp);
158    console.log("Last run:", payload.lastTimestamp);
159    console.log("Timezone:", payload.timezone);
160    console.log("Next 5 runs:", payload.upcoming);
161 
162    await sendDigestForDate(payload.timestamp);
163  },
164});
165```
166 
167Για schedules per-tenant - ας πούμε, ένα cron ανά πελάτη - τα δημιουργείτε δυναμικά μέσω του management API.
168 
169```typescript
170import { schedules } from "@trigger.dev/sdk";
171 
172await schedules.create({
173  task: "daily-digest",
174  cron: "0 9 * * *",
175  timezone: "America/New_York",
176  externalId: `customer_${customerId}`,
177  deduplicationKey: `digest-${customerId}`,
178});
179```
180 
181Το `deduplicationKey` καθιστά την κλήση idempotent: η εκ νέου εκτέλεση του ίδιου κώδικα κατά την ώρα του deploy δεν στοιβάζει διπλασιασμένα schedules.
182 
183## Ουρές, ταυτόχρονη εκτέλεση και idempotency
184 
185Τρία primitives καλύπτουν τις περισσότερες ανάγκες rate-limiting και ταξινόμησης.
186 
187```mermaid
188graph TB
189    Trigger[trigger payload] --> IK{idempotencyKey<br/>είδες;}
190    IK -->|ναι| Reuse[Επιστροφή υπάρχοντος run]
191    IK -->|όχι| CK[bucket concurrencyKey]
192    CK --> Q[Ουρά με<br/>concurrencyLimit]
193    Q -->|slot διαθέσιμο| Run[Εκτέλεση task]
194    Q -->|slots γεμάτα| Wait[Αναμονή στην ουρά]
195```
196 
197Ένα κοινό μοτίβο: μία ουρά ανά tenant με μικρή per-key ταυτόχρονη εκτέλεση για να σεβαστείτε το rate limit ενός vendor, συν ένα idempotency key για να κάνετε τα retries ασφαλή.
198 
199```typescript
200await syncShopifyOrders.trigger(
201  { shopId },
202  {
203    queue: { name: `shopify-${shopId}`, concurrencyLimit: 2 },
204    concurrencyKey: shopId,
205    idempotencyKey: `sync-${shopId}-${Date.now() / 60_000 | 0}`,
206  }
207);
208```
209 
210## Αναμονές και εργασία μεγάλης διάρκειας
211 
212Τα tasks μπορούν να σταματήσουν χωρίς να κρατούν σύνδεση ή να καίνε compute. Η πλατφόρμα διατηρεί την κατάσταση και επαναφέρει τη συνάρτηση όταν η αναμονή ολοκληρωθεί.
213 
214```typescript
215import { wait } from "@trigger.dev/sdk";
216 
217export const onboarding = task({
218  id: "onboarding",
219  run: async (payload: { userId: string }) => {
220    await sendWelcomeEmail.triggerAndWait({ userId: payload.userId });
221    await wait.for({ days: 1 });
222    await sendTipsEmail.trigger({ userId: payload.userId });
223    await wait.until({ date: oneWeekFromSignup(payload.userId) });
224    await sendUpgradeOffer.trigger({ userId: payload.userId });
225  },
226});
227```
228 
229Το `triggerAndWait` είναι το killer feature: ενεργοποιεί ένα child task και αναστέλλει το parent μέχρι να ολοκληρωθεί το child. Συνθέτετε tasks σαν async συναρτήσεις, αλλά η ενορχήστρωση τρέχει ανθεκτικά για ημέρες ή εβδομάδες.
230 
231### Human-in-the-loop με `wait.forToken`
232 
233Για ροές έγκρισης και AI gates, το `wait.forToken` σταματάει μέχρι η εφαρμογή σας να καλέσει πίσω με ένα αποτέλεσμα.
234 
235```typescript
236import { task, wait } from "@trigger.dev/sdk";
237 
238export const publishPost = task({
239  id: "publish-post",
240  run: async (payload: { draftId: string }) => {
241    const draft = await generateAIContent(payload.draftId);
242 
243    const token = await wait.createToken({ timeout: "7d" });
244    await notifyEditor({ draftId: draft.id, token: token.id });
245 
246    const decision = await wait.forToken<{ approved: boolean; notes?: string }>(
247      token.id
248    );
249 
250    if (decision.approved) {
251      return await publish(draft);
252    }
253    return await applyFeedback(draft, decision.notes);
254  },
255});
256```
257 
258Ο επεξεργαστής ανοίγει ένα UI, αναθεωρεί το πρόχειρο, κάνει κλικ στο Approve και το backend σας ολοκληρώνει το token. Το task συνεχίζει από εκεί που σταμάτησε - ακόμη και αν έχουν περάσει ώρες ή ημέρες.
259 
260## Lifecycle Hooks
261 
262Μπορείτε να επισυνάψετε `init`, `onStart`, `onSuccess` και `onFailure` σε ένα task ή παγκοσμίως στο `trigger.config.ts`. Χρησιμοποιήστε τα για tracing, error reporting και κοινόχρηστο setup.
263 
264```typescript
265// trigger.config.ts
266export default defineConfig({
267  // ...
268  init: async () => {
269    Sentry.init({ dsn: process.env.SENTRY_DSN });
270  },
271  onFailure: async ({ error, ctx }) => {
272    Sentry.captureException(error, {
273      tags: { taskId: ctx.task.id, runId: ctx.run.id },
274    });
275  },
276});
277```
278 
279Το `init` τρέχει μία φορά ανά worker container κατά την εκκίνηση, όχι ανά run, οπότε είναι το σωστό μέρος για να ρυθμίσετε clients και pools.
280 
281## Realtime στο Frontend
282 
283Το Trigger.dev δημοσιεύει αλλαγές κατάστασης run - status, metadata, output - μέσω ενός streaming API. Τα React hooks εγγράφονται σε αυτό το stream και κάνουν re-render αυτόματα.
284 
285```typescript
286// trigger/process-video.ts
287import { task, metadata } from "@trigger.dev/sdk";
288 
289export const processVideo = task({
290  id: "process-video",
291  run: async (payload: { videoId: string }) => {
292    metadata.set("stage", "transcoding");
293    await transcode(payload.videoId);
294 
295    metadata.set("stage", "thumbnails");
296    await generateThumbnails(payload.videoId);
297 
298    metadata.set("stage", "uploading");
299    const url = await uploadToCDN(payload.videoId);
300 
301    return { url };
302  },
303});
304```
305 
306```tsx
307// components/VideoStatus.tsx
308"use client";
309import { useRealtimeRun } from "@trigger.dev/react-hooks";
310import type { processVideo } from "@/trigger/process-video";
311 
312export function VideoStatus({
313  runId,
314  publicAccessToken,
315}: {
316  runId: string;
317  publicAccessToken: string;
318}) {
319  const { run, error } = useRealtimeRun<typeof processVideo>(runId, {
320    accessToken: publicAccessToken,
321  });
322 
323  if (error) return <p>Error: {error.message}</p>;
324  if (!run) return <p>Loading...</p>;
325 
326  return (
327    <div>
328      <p>Status: {run.status}</p>
329      <p>Stage: {String(run.metadata?.stage ?? "queued")}</p>
330      {run.output?.url && <video src={run.output.url} controls />}
331    </div>
332  );
333}
334```
335 
336Δημιουργείτε το public access token στην πλευρά του server, scoped σε ένα συγκεκριμένο run, και το στέλνετε στον client. Το hook χειρίζεται το auth, την επανασύνδεση και τις σταδιακές ενημερώσεις.
337 
338Για trigger-and-subscribe σε ένα βήμα:
339 
340```tsx
341import { useRealtimeTaskTrigger } from "@trigger.dev/react-hooks";
342 
343const { submit, run, isLoading } = useRealtimeTaskTrigger<typeof processVideo>(
344  "process-video",
345  { accessToken: publicAccessToken }
346);
347 
348<button onClick={() => submit({ videoId })} disabled={isLoading}>
349  Process video
350</button>;
351```
352 
353## AI Agents και Streaming
354 
355Το Trigger.dev έχει γίνει ένα δημοφιλές runtime για AI agents επειδή τα ίδια primitives - ανθεκτική εκτέλεση, retries, αναμονές, real-time metadata, human-in-the-loop - είναι ακριβώς αυτό που χρειάζονται οι agents. Streamάρετε tokens από έναν model provider στο `metadata` ενώ το run εκτελείται, το frontend τα κάνει render ζωντανά και το run επιβιώνει από tool calls μεγάλης διάρκειας χωρίς να καίει ένα serverless timeout.
356 
357```typescript
358import { task, metadata } from "@trigger.dev/sdk";
359import { streamText } from "ai";
360import { anthropic } from "@ai-sdk/anthropic";
361 
362export const researchAgent = task({
363  id: "research-agent",
364  maxDuration: 1800,
365  run: async (payload: { question: string }) => {
366    const result = streamText({
367      model: anthropic("claude-opus-4-7"),
368      system: "You are a research assistant. Use the web.",
369      prompt: payload.question,
370      tools: { webSearch },
371    });
372 
373    let fullText = "";
374    for await (const chunk of result.textStream) {
375      fullText += chunk;
376      metadata.set("partial", fullText);
377    }
378 
379    return { answer: fullText, usage: await result.usage };
380  },
381});
382```
383 
384Το frontend χρησιμοποιεί το `useRealtimeRun` και διαβάζει το `run.metadata.partial` για να κάνει render την streaming απάντηση, με τον ίδιο τρόπο που θα κάνατε render μια chat completion - εκτός από το ότι αυτή επιβιώνει σε πλήρες reload σελίδας.
385 
386## Deploying
387 
388Τα deploys μεταγλωττίζουν τα tasks σας σε ένα versioned bundle, χτίζουν ένα container και ανταλλάσσουν την κίνηση ατομικά. Τα παλιά in-flight runs συνεχίζουν να χρησιμοποιούν την προηγούμενη έκδοση.
389 
390```bash
391npx trigger.dev@latest deploy --env prod
392```
393 
394Στο CI συνήθως συνδέετε αυτό με το ίδιο workflow που στέλνει την εφαρμογή σας:
395 
396```yaml
397# .github/workflows/deploy.yml
398- name: Deploy Trigger.dev
399  env:
400    TRIGGER_ACCESS_TOKEN: ${{ secrets.TRIGGER_ACCESS_TOKEN }}
401  run: npx trigger.dev@latest deploy --env prod
402```
403 
404Για περιβάλλοντα preview, περάστε `--env preview --branch ${{ github.head_ref }}` και το Trigger.dev δημιουργεί ένα απομονωμένο περιβάλλον ανά branch, αντικατοπτρίζοντας τον τρόπο με τον οποίο το Vercel χειρίζεται τα preview deployments.
405 
406## Self-Hosting vs Cloud
407 
408Το Trigger.dev είναι ανοικτού κώδικα υπό την άδεια Apache 2.0. Μπορείτε να κάνετε self-host σε οποιαδήποτε πλατφόρμα container (Docker Compose, Kubernetes, Fly.io) ή να χρησιμοποιήσετε το διαχειριζόμενο cloud στο trigger.dev.
409 
410| Πτυχή | Cloud | Self-hosted |
411|--------|-------|-------------|
412| **Setup** | Εγγραφή, εκτέλεση `init` | Εκτέλεση docker-compose ή Helm chart |
413| **Scaling** | Αυτόματο | Δική σας ευθύνη |
414| **Pricing** | Ανά run + ανά compute | Μόνο κόστος infra |
415| **Compliance** | SOC 2 | Ό,τι παρέχει το περιβάλλον σας |
416| **Καλύτερο για** | Τις περισσότερες ομάδες | Αυστηρή κατοικία δεδομένων, custom infra |
417 
418Το SDK και το CLI είναι πανομοιότυπα μεταξύ των τρόπων - αλλάζετε ένα profile flag και δείχνετε στο δικό σας instance.
419 
420## Best Practices
421 
422### 1. Κρατήστε τα payloads μικρά και σειριοποιήσιμα
423 
424Περάστε IDs και αναφορές, όχι πλήρη αντικείμενα. Τραβήξτε τα δεδομένα μέσα στο task. Αυτό κρατάει την ουρά μικρή, τα payloads φθηνά να καταγραφούν και σας επιτρέπει να αλλάξετε την πηγή δεδομένων χωρίς re-trigger.
425 
426### 2. Idempotency keys σε κάθε εξωτερική κλήση
427 
428Συνδυάστε το `idempotencyKey` στο trigger του task με idempotency keys στα APIs των vendors σας (Stripe, OpenAI, κλπ). Τα retries θα είναι ασφαλή end-to-end.
429 
430### 3. Χρησιμοποιήστε το `triggerAndWait` για ενορχήστρωση, όχι `Promise.all` από triggers
431 
432Ένας parent που καλεί `triggerAndWait` συνθέτει ανθεκτικά child tasks. Ένας parent που τρενάρει και επιλύει αμέσως χάνει την παρατηρησιμότητα της αλυσίδας.
433 
434### 4. Tagάρετε τα runs
435 
436Προσθέστε `tags` στα triggers (`tags: ["user:123", "feature:onboarding"]`) ώστε να μπορείτε να φιλτράρετε το dashboard και το management API ανά επιχειρηματικές διαστάσεις.
437 
438### 5. Κρατήστε το `init` idempotent
439 
440Τρέχει σε κάθε cold start. Αποφύγετε migrations ή one-shot παρενέργειες εκεί.
441 
442## Συμπέρασμα
443 
444Το Trigger.dev αφαιρεί τις κατηγορίες εργασίας που παλιότερα απαιτούσαν να χτίσετε ένα job system από την αρχή. Γράφετε async TypeScript, το καλείτε από οπουδήποτε και η πλατφόρμα σας δίνει ανθεκτική εκτέλεση, scheduling, ουρές, retries, real-time ενημερώσεις και πρότυπα human-in-the-loop out of the box.
445 
446Η ίδια επιφάνεια που τροφοδοτεί ένα νυχτερινό cron είναι η επιφάνεια που τροφοδοτεί έναν multi-step AI agent που streamάρει στο frontend και σταματάει για review. Αυτή η σύγκλιση είναι αυτό που κάνει το framework άξιο σοβαρής ματιάς το 2026, είτε διαχειρίζεστε ένα SaaS που χρειάζεται αξιόπιστη εργασία παρασκηνίου είτε αποστέλλετε χαρακτηριστικά AI που επιβιώνουν από ένα serverless timeout.
447 
448> **Checklist Εκκίνησης:**
449>
450> - [x] Εγγραφείτε στο trigger.dev ή τρέξτε το self-hosted Docker stack
451> - [x] `npx trigger.dev@latest init` στο έργο σας
452> - [x] Ορίστε το πρώτο σας task με `task({ id, run })`
453> - [x] Triggerάρετέ το από το API σας και δείτε το run στο dashboard
454> - [x] Προσθέστε `idempotencyKey` και `concurrencyKey` για ασφάλεια production
455> - [x] Συνδέστε το `useRealtimeRun` με ένα status component
456> - [x] Κάντε deploy με `trigger.dev deploy --env prod` από το CI
457