1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
SQLite format 3 @ .zp
� . ��
IX% t �
5Y��W�&�. q1 � indexidx_pipelines_namepipelinesCREATE INDEX idx_pipelines_name ON pipelines(name)
WHERE archived = false�G-� indexidx_stage_parameters_stage_idstage_parametersCREATE INDEX idx_stage_parameters_stage_id ON stage_parameters(stage_id)�#Y9�Aindexidx_pipeline_configuration_pipeline_idpipeline_configurationCREATE INDEX idx_pipeline_configuration_pipeline_id ON pipeline_configuration(pipeline_id)�?+�3indexidx_pipeline_stages_orderpipeline_stagesCREATE INDEX idx_pipeline_stages_order ON pipeline_stages(pipeline_id, stage_order)�K+�%indexidx_pipeline_stages_pipeline_idpipeline_stagesCREATE INDEX idx_pipeline_stages_pipeline_id ON pipeline_stages(pipeline_id)�0 11� tableprocessing_metricsprocessing_metrics
CREATE TABLE processing_metrics (
pipeline_id TEXT PRIMARY KEY,
bytes_processed INTEGER NOT NULL DEFAULT 0,
bytes_total INTEGER NOT NULL DEFAULT 0,
chunks_processed INTEGER NOT NULL DEFAULT 0,
chunks_total INTEGER NOT NULL DEFAULT 0,
start_time_rfc3339 TEXT,
end_time_rfc3339 TEXT,
processing_duration_ms INTEGER,
throughput_bytes_per_second REAL NOT NULL DEFAULT 0.0,
compression_ratio REAL,
error_count INTEGER NOT NULL DEFAULT 0,
warning_count INTEGER NOT NULL DEFAULT 0,
input_file_size_bytes INTEGER NOT NULL DEFAULT 0,
output_file_size_bytes INTEGER NOT NULL DEFAULT 0,
input_file_checksum TEXT,
output_file_checksum TEXT,
FOREIGN KEY (pipeline_id) REFERENCES pipelines(id) ON DELETE CASCADE
)C
W1 indexsqlite_autoindex_processing_metrics_1processing_metrics�p
--�tablestage_parametersstage_parameters CREATE TABLE stage_parameters (
stage_id TEXT NOT NULL,
key TEXT NOT NULL,
value TEXT NOT NULL,
archived BOOLEAN NOT NULL DEFAULT FALSE,
created_at TEXT NOT NULL,
updated_at TEXT NOT NULL,
PRIMARY KEY (stage_id, key),
FOREIGN KEY (stage_id) REFERENCES pipeline_stages(id) ON DELETE CASCADE
)? S- indexsqlite_autoindex_stage_parameters_1stage_parameters �%++�tablepipeline_stagespipeline_stages CREATE TABLE pipeline_stages (
id TEXT PRIMARY KEY,
pipeline_id TEXT NOT NULL,
name TEXT NOT NULL,
stage_type TEXT NOT NULL,
enabled BOOLEAN NOT NULL DEFAULT TRUE,
stage_order INTEGER NOT NULL,
algorithm TEXT NOT NULL,
parallel_processing BOOLEAN NOT NULL DEFAULT FALSE,
chunk_size INTEGER,
archived BOOLEAN NOT NULL DEFAULT FALSE,
created_at TEXT NOT NULL,
updated_at TEXT NOT NULL,
FOREIGN KEY (pipeline_id) REFERENCES pipelines(id) ON DELETE CASCADE
)= Q+ indexsqlite_autoindex_pipeline_stages_1pipeline_stages
�99�%tablepipeline_configurationpipeline_configurationCREATE TABLE pipeline_configuration (
pipeline_id TEXT NOT NULL,
key TEXT NOT NULL,
value TEXT NOT NULL,
archived BOOLEAN NOT NULL DEFAULT FALSE,
created_at TEXT NOT NULL,
updated_at TEXT NOT NULL,
PRIMARY KEY (pipeline_id, key),
FOREIGN KEY (pipeline_id) REFERENCES pipelines(id) ON DELETE CASCADE
)K_9 indexsqlite_autoindex_pipeline_configuration_1pipeline_configuration�Y �tablepipelinespipelinesCREATE TABLE pipelines (
id TEXT PRIMARY KEY,
name TEXT NOT NULL UNIQUE,
archived BOOLEAN NOT NULL DEFAULT false,
created_at TEXT NOT NULL,
updated_at TEXT NOT NULL
)1E indexsqlite_autoindex_pipelines_2pipelines1E indexsqlite_autoindex_pipelines_1pipelines�)--�table_sqlx_migrations_sqlx_migrationsCREATE TABLE _sqlx_migrations (
version BIGINT PRIMARY KEY,
description TEXT NOT NULL,
installed_on TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
success BOOLEAN NOT NULL,
checksum BLOB NOT NULL,
execution_time BIGINT NOT NULL
)?S- indexsqlite_autoindex__sqlx_migrations_1_sqlx_migrations
� � a)3 lj��@initial schema2025-10-07 23:09:35�a�OG��|�(g�D���3���I�T�lMu���D�Skm� �ZI�-�2
� � j��@