✨ Langfuse Agentic Workflow Editor + MCP 구현

.env.dev.example

@@ -156,3 +156,7 @@ LANGFUSE_ENABLE_EVENTS_TABLE_V2_APIS=true
 LANGFUSE_EXPERIMENT_INSERT_INTO_EVENTS_TABLE=true
 
 CLICKHOUSE_USE_LIGHTWEIGHT_UPDATE="true"
+
+# Workflow Tool: Standards Search API (Python service)
+WORKFLOW_TOOL_SEARCH_API_URL=http://localhost:8000
+WORKFLOW_TOOL_SEARCH_API_KEY=your_search_api_key

.gitignore

@@ -81,3 +81,6 @@ web/test-results/*
 
 # Refactoring planning files (local only)
 **/.refactor/
+
+# OMC state files
+.omc/

packages/shared/prisma/generated/types.ts

@@ -947,6 +947,22 @@ export type VerificationToken = {
   token: string;
   expires: Timestamp;
 };
+export type Workflow = {
+  id: string;
+  created_at: Generated<Timestamp>;
+  updated_at: Generated<Timestamp>;
+  project_id: string;
+  created_by: string;
+  name: string;
+  description: Generated<string>;
+  version: number;
+  tags: Generated<string[]>;
+  definition: unknown;
+  input_schema: unknown | null;
+  last_execution_at: Timestamp | null;
+  last_execution_results: unknown | null;
+  last_execution_status: string | null;
+};
 export type DB = {
   Account: Account;
   actions: Action;
@@ -1011,4 +1027,5 @@ export type DB = {
   triggers: Trigger;
   users: User;
   verification_tokens: VerificationToken;
+  workflows: Workflow;
 };

packages/shared/prisma/migrations/20260307003444_add_workflows/migration.sql

@@ -0,0 +1,34 @@
+-- CreateTable
+CREATE TABLE "workflows" (
+    "id" TEXT NOT NULL,
+    "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updated_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "project_id" TEXT NOT NULL,
+    "created_by" TEXT NOT NULL,
+    "name" TEXT NOT NULL,
+    "description" TEXT NOT NULL DEFAULT '',
+    "version" INTEGER NOT NULL,
+    "tags" TEXT[] DEFAULT ARRAY[]::TEXT[],
+    "definition" JSONB NOT NULL,
+    "input_schema" JSONB,
+
+    CONSTRAINT "workflows_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "workflows_project_id_name_version_key" ON "workflows"("project_id", "name", "version");
+
+-- CreateIndex
+CREATE INDEX "workflows_project_id_id_idx" ON "workflows"("project_id", "id");
+
+-- CreateIndex
+CREATE INDEX "workflows_created_at_idx" ON "workflows"("created_at");
+
+-- CreateIndex
+CREATE INDEX "workflows_updated_at_idx" ON "workflows"("updated_at");
+
+-- CreateIndex
+CREATE INDEX "workflows_tags_idx" ON "workflows" USING GIN ("tags");
+
+-- AddForeignKey
+ALTER TABLE "workflows" ADD CONSTRAINT "workflows_project_id_fkey" FOREIGN KEY ("project_id") REFERENCES "projects"("id") ON DELETE CASCADE ON UPDATE CASCADE;

packages/shared/prisma/migrations/20260307171547_add_workflow_execution_history/migration.sql

@@ -0,0 +1,4 @@
+-- AlterTable
+ALTER TABLE "workflows" ADD COLUMN "last_execution_at" TIMESTAMP(3),
+ADD COLUMN "last_execution_results" JSONB,
+ADD COLUMN "last_execution_status" TEXT;

packages/shared/prisma/schema.prisma

@@ -162,6 +162,7 @@ model Project {
   PromptDependency          PromptDependency[]
   LlmSchema                 LlmSchema[]
   LlmTool                   LlmTool[]
+  Workflow                  Workflow[]
   PromptProtectedLabels     PromptProtectedLabels[]
   Dashboard                 Dashboard[]
   DashboardWidget           DashboardWidget[]
@@ -809,6 +810,38 @@ model PromptDependency {
   @@map("prompt_dependencies")
 }
 
+model Workflow {
+  id        String   @id @default(cuid())
+  createdAt DateTime @default(now()) @map("created_at")
+  updatedAt DateTime @default(now()) @updatedAt @map("updated_at")
+
+  projectId String  @map("project_id")
+  project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade)
+
+  createdBy String @map("created_by")
+
+  name        String
+  description String  @default("")
+  version     Int
+  tags        String[] @default([])
+
+  // Entire graph stored as JSON: { nodes: WorkflowNodeDef[], edges: WorkflowEdgeDef[] }
+  definition  Json    @db.Json
+
+  inputSchema Json?   @map("input_schema") @db.Json
+
+  lastExecutionAt      DateTime? @map("last_execution_at")
+  lastExecutionResults Json?     @map("last_execution_results") @db.Json
+  lastExecutionStatus  String?   @map("last_execution_status")
+
+  @@unique([projectId, name, version])
+  @@index([projectId, id])
+  @@index([createdAt])
+  @@index([updatedAt])
+  @@index([tags(ops: ArrayOps)], type: Gin)
+  @@map("workflows")
+}
+
 model PromptProtectedLabels {
   id        String   @id @default(cuid())
   createdAt DateTime @default(now()) @map("created_at")