n8n/docs/generated/postgres-schema/public.agent_message_queue.md

public.agent_message_queue

Columns

Name	Type	Default	Nullable	Children	Parents	Comment
agentId	varchar(36)		false		public.agents	Agent that processes this input.
createdAt	timestamp(3) with time zone	CURRENT_TIMESTAMP(3)	false
executionId	varchar(36)		true		public.agent_execution	Execution recording for the active input.
id	bigint		false
kind	varchar(16)		false			Ordinary message or human response to a suspended run.
payload	json		false			Typed input and actor, project, and reply routing data.
source	varchar(16)		false			Preview HTTP request or integration chat input.
status	varchar(16)		false			Waiting, active, or cancelling input.
threadId	varchar(128)		false			Existing conversation routing ID.
updatedAt	timestamp(3) with time zone	CURRENT_TIMESTAMP(3)	false

Constraints

Name	Type	Definition
CHK_agent_message_queue_kind	CHECK	CHECK (((kind)::text = ANY ((ARRAY['message'::character varying, 'hitl'::character varying])::text[])))
CHK_agent_message_queue_source	CHECK	CHECK (((source)::text = ANY ((ARRAY['preview'::character varying, 'integration'::character varying])::text[])))
CHK_agent_message_queue_status	CHECK	CHECK (((status)::text = ANY ((ARRAY['queued'::character varying, 'processing'::character varying, 'cancelling'::character varying])::text[])))
FK_2349d84b4f2a660fc264f38fef3	FOREIGN KEY	FOREIGN KEY ("executionId") REFERENCES agent_execution(id) ON DELETE SET NULL
FK_8a5699c954416a2172688ff39fa	FOREIGN KEY	FOREIGN KEY ("agentId") REFERENCES agents(id) ON DELETE CASCADE
PK_733d8c959a6057f04f4da5ab721	PRIMARY KEY	PRIMARY KEY (id)
agent_message_queue_agentId_not_null	n	NOT NULL "agentId"
agent_message_queue_createdAt_not_null	n	NOT NULL "createdAt"
agent_message_queue_id_not_null	n	NOT NULL id
agent_message_queue_kind_not_null	n	NOT NULL kind
agent_message_queue_payload_not_null	n	NOT NULL payload
agent_message_queue_source_not_null	n	NOT NULL source
agent_message_queue_status_not_null	n	NOT NULL status
agent_message_queue_threadId_not_null	n	NOT NULL "threadId"
agent_message_queue_updatedAt_not_null	n	NOT NULL "updatedAt"

Indexes

Name	Definition
IDX_0d7ab2b181c282217497591502	CREATE INDEX "IDX_0d7ab2b181c282217497591502" ON public.agent_message_queue USING btree ("threadId", status, kind, id)
IDX_832d536d7954194b88e0edb5bd	CREATE INDEX "IDX_832d536d7954194b88e0edb5bd" ON public.agent_message_queue USING btree (status, "updatedAt")
IDX_8a5699c954416a2172688ff39f	CREATE INDEX "IDX_8a5699c954416a2172688ff39f" ON public.agent_message_queue USING btree ("agentId")
IDX_agent_message_queue_executionId	CREATE UNIQUE INDEX "IDX_agent_message_queue_executionId" ON public.agent_message_queue USING btree ("executionId") WHERE ("executionId" IS NOT NULL)
PK_733d8c959a6057f04f4da5ab721	CREATE UNIQUE INDEX "PK_733d8c959a6057f04f4da5ab721" ON public.agent_message_queue USING btree (id)

Relations

erDiagram

"public.agent_message_queue" }o--|| "public.agents" : "FOREIGN KEY (#quot;agentId#quot;) REFERENCES agents(id) ON DELETE CASCADE"
"public.agent_message_queue" }o--o| "public.agent_execution" : "FOREIGN KEY (#quot;executionId#quot;) REFERENCES agent_execution(id) ON DELETE SET NULL"

"public.agent_message_queue" {
  varchar_36_ agentId FK
  timestamp_3__with_time_zone createdAt
  varchar_36_ executionId FK
  bigint id
  varchar_16_ kind
  json payload
  varchar_16_ source
  varchar_16_ status
  varchar_128_ threadId
  timestamp_3__with_time_zone updatedAt
}
"public.agents" {
  varchar_36_ activeVersionId FK
  boolean availableInMCP
  timestamp_3__with_time_zone createdAt
  varchar_36_ id
  json integrations
  varchar_128_ name
  varchar_255_ projectId FK
  integer revision
  json schema
  timestamp_3__with_time_zone setupCompletedAt
  json skills
  json tools
  timestamp_3__with_time_zone updatedAt
  varchar_36_ versionId
}
"public.agent_execution" {
  json attachments
  json author
  integer completionTokens
  double_precision cost
  timestamp_3__with_time_zone createdAt
  integer duration
  text error
  json failureSummary
  varchar_16_ hitlStatus
  varchar_36_ id
  varchar_255_ model
  integer promptTokens
  varchar_32_ source
  timestamp_3__with_time_zone startedAt
  varchar_16_ status
  timestamp_3__with_time_zone stoppedAt
  varchar_2_ storedAt
  varchar_128_ threadId FK
  json timeline
  integer totalTokens
  timestamp_3__with_time_zone updatedAt
  text userMessage
}

---

Generated by tbls