dag-core / Exports / IQueueMessage

Interface: IQueueMessage

Message dispatched to the task queue for worker consumption.

Table of contents

Properties

• messageId
• dagRunId
• taskRunId
• nodeId
• attempt
• executionPath
• payload
• createdAt

Properties

messageId

• messageId: string

Defined in

interfaces/ports.ts:46

---

dagRunId

• dagRunId: string

Defined in

interfaces/ports.ts:47

---

taskRunId

• taskRunId: string

Defined in

interfaces/ports.ts:48

---

nodeId

• nodeId: string

Defined in

interfaces/ports.ts:49

---

attempt

• attempt: number

Defined in

interfaces/ports.ts:50

---

executionPath

• executionPath: string[]

Defined in

interfaces/ports.ts:51

---

payload

• payload: TPortPayload

Defined in

interfaces/ports.ts:52

---

createdAt

• createdAt: string

Defined in

interfaces/ports.ts:53