Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions crates/nvisy-nats/src/stream/event.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
//! Event types for stream processing.
//!
//! This module contains common event types and the file job type
//! used in processing pipelines.
//! used in redaction pipelines.

use jiff::Timestamp;
#[cfg(feature = "schema")]
Expand All @@ -12,7 +12,7 @@ use uuid::Uuid;

/// File processing job.
///
/// Represents a unit of work in a file processing pipeline.
/// Represents a unit of work in a file redaction pipeline.
/// Each job targets a specific file and carries a generic payload
/// that defines the processing parameters.
///
Expand Down
4 changes: 2 additions & 2 deletions migrations/2026-01-19-045012_pipelines/up.sql
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
-- Pipeline: Workflow definitions, connections, and execution tracking
-- This migration creates tables for user-defined processing pipelines
-- This migration creates tables for redaction pipeline definitions

-- Sync status enum for connections
CREATE TYPE SYNC_STATUS AS ENUM (
Expand Down Expand Up @@ -269,7 +269,7 @@ CREATE INDEX workspace_pipelines_name_trgm_idx

-- Comments
COMMENT ON TABLE workspace_pipelines IS
'User-defined processing pipeline definitions with step configurations.';
'Redaction pipeline definitions with step configurations.';

COMMENT ON COLUMN workspace_pipelines.id IS 'Unique pipeline identifier';
COMMENT ON COLUMN workspace_pipelines.workspace_id IS 'Parent workspace reference';
Expand Down