bpm-engine 0.1.0

Lightweight embeddable BPM runtime for long-running, stateful workflows with tokens, timers, Saga compensation, and crash recovery
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

SQLite format 3@  ��.v�

�
	�G�
��
W�^
�	�
��W	''�mtableparallel_joinparallel_join
CREATE TABLE parallel_join (
    group_id TEXT PRIMARY KEY,
    expected INTEGER NOT NULL,
    arrived_count INTEGER NOT NULL DEFAULT 0,
    joined INTEGER NOT NULL DEFAULT 0
)9
M'indexsqlite_autoindex_parallel_join_1parallel_join�a�tabletokenstokensCREATE TABLE tokens (
    id TEXT PRIMARY KEY,
    instance_id TEXT NOT NULL,
    node_id TEXT NOT NULL,
    waiting INTEGER NOT NULL, status TEXT NOT NULL DEFAULT 'Ready', mode TEXT NOT NULL DEFAULT 'Forward', version INTEGER NOT NULL DEFAULT 0, updated_at TEXT,
    FOREIGN KEY (instance_id) REFERENCES process_instances(id)
)�
//�Itableprocess_instancesprocess_instancesCREATE TABLE process_instances (
    id TEXT PRIMARY KEY,
    process_def_id TEXT NOT NULL,
    variables TEXT NOT NULL,
    completed INTEGER NOT NULL,
    created_at TEXT NOT NULL
, state TEXT NOT NULL DEFAULT 'Running')c9�indexidx_tokens_instance_idtokensCREATE INDEX idx_tokens_instance_id ON tokens(instance_id)�A�tabletokenstokensCREATE TABLE tokens (
    id 	_/%yindexidx_outbox_statusoutbox_event	CREATE INDEX idx_outbox_status ON outbox_event(status)7K%indexsqlite_autoindex_outbox_event_1outbox_event�+?indexsqlite_autoindex_tokens_1tokens�0//�{tableprocess_instancesprocess_instance�6%%�/tableoutbox_eventoutbox_eventCREATE TABLE outbox_event (
    id TEXT PRIMARY KEY,
    payload TEXT NOT NULL,
    status TEXT NOT NULL DEFAULT 'Pending',
    created_at TEXT
)AU/indexsqlite_autoindex_process_instances_1process_instances

�h��Z�R
�
�
P�hFU!755a1f4c-9b18-47bf-9ace-5df164e4d8fbapproval{}1769737349RunningF
U!0ee534e0-99f9-47bd-8d43-489d2d658566approval{}1769736732RunningVU-	!bbf765ea-d945-44c5-b9d0-2195e77744c0approval{"valid":"true"}1769734893Completed>	U!d3c45da5-fd59-4149-b0e7-481b04f4385fapproval{}1769736139-	!4ab9f3d8-7VU-	!4ab9f3d8-7f00-47c5-bd08-d5efbf30a070approval{"valid":"true"}1769736053CompletedVU-	!c02eded7-f172-4855-9c60-bf5f63734e78approval{"valid":"true"}1769735840CompletedVU-	!8f888c62-077a-4b50-a834-098c2dcd9e74approval{"valid":"true"}1769735052CompletedVU-	!40cf899c-ea08-4217-b03d-cf3db82f1772approval{"valid":"true"}1769734969CompletedVU-	!0ce55144-5f9f-45a4-bd8a-bc0c68d73909approval{"valid":"true"}1769734964CompletedVU-	!e6b369a2-ff2d-4119-bb6a-27a2c9cf4a99approval{"valid":"true"}1769734907CompletedLU-!edacfa56-567d-41e4-b5d3-9682dc1f449dapproval{"valid":"true"}1769734839
>]g4�>�����(U755a1f4c-9b18-47bf-9ace-5df164e4d8fb(U0ee534e0-99f9-47bd-8d43-489d2d658566
(Ud3c45da5-fd59-4149-b0e7-481b04f4385f	(U4ab9f3d8-7f00-47c5-bd08-d5efbf30a070(Uc02eded7-f172-4855-9c60-bf5f63734e78(U8f888c62-077a-4b50-a834-098c2dcd9e74(U40cf899c-ea08-4217-b03d-cf3db82f1772(U0ce55144-5f9f-45a4-bd8a-bc0c68d73909(Ue6b369a2-ff2d-4119-bb6a-27a2c9cf4a99(Ubbf765ea-d945-44c5-b9d0-2195e77744c0'U	edacfa56-567d-41e4-b5d3-9682dc1f449d
���/�`>
��
C�rF�|
�
5	��	J��@��-��<�d	UU	8b985f8b-8f29-4b06-8ef9-57f566eb3c9e4ab9f3d8-7f00-47c5-bd08-d5efbf30a070startWaitingForwardd	UU	4458ef7f-8d3f-4938-b409-91c3b30dfc64c02eded7-f172-4855-9c60-bf5f63734e78startWaitingForwardd	UU	8e46e339-f691-4eb4-bba1-0606c979ea818f888c62-077a-4b50-a834-098c2dcd9e74startWaitingForwardd	UU	6f15a073-41b8-4e61-8222-4a9c70f472c440cf899c-ea08-4217-b03d-cf3db82f1772startWaitingForwardd	UU	3050c63d-14d6-433e-a94e-8a1a2a35474c0ce55144-5f9f-45a4-bd8a-bc0c68d73909startWaitingForwardd	UU	5cfe0864-3f7d-4841-92b4-07b2a50f69a1e6b369a2-ff2d-4119-bb6a-27a2c9cf4a99startWaitingForwardf	UU	924ed0c1-fad0-4304-8eca-b26692ac3e22bbf765ea-d945-44c5-b9d0-2195e77744c0approveWaitingForwardd	UU	e81ff2c5-fa9e-4b21-88c5-13823d248c0dedacfa56-567d-41e4-b5d3-9682dc1f449dstartWaitingForward
0U	5963d86c-50b4-429f-89ad-187ea33d37b64ab9ff	UU	5963d86c-50b4-429f-89ad-187ea33d37b64ab9f3d8-7f00-47c5-bd08-d5efbf30a070gatewayWaitingForwardg	UU	379b3a0f-162f-4c92-b338-4339a84865794ab9f3d8-7f00-47c5-bd08-d5efbf30a070validateWaitingForward` Udb1f7448-b33e-4aac-9211-a`	UUdb1f7448-b33e-4aac-9211-a84e968112a2c02eded7-f172-4855-9c60-bf5f63734e78endReadyForwardf	UU	9e441c10-d65f-410b-a821-ccb83fab1df0c02eded7-f172-4855-9c60-bf5f63734e78gatewayWaitingForwardg	UU	a29294e9-ba23-4cf4-966d-58404693dc52c02eded7-f172-4855-9c60-bf5f63734e78validateWaitingForward	� Ub38ec5dc-dee2-43fb-b030-7`	UUb38ec5dc-dee2-43fb-b030-7a4330ec54568f888c62-077a-4b50-a834-098c2dcd9e74endReadyForwardf	UU	bb88b3c1-7179-4f12-bc89-75abc0c42daa8f888c62-077a-4b50-a834-098c2dcd9e74gatewayWaitingForwardg	UU	18a7a5bd-3896-4b51-9aa0-9d50adf87bc18f888c62-077a-4b50-a834-098c2dcd9e74validateWaitingForward Ua0f87780-a7fd-46c9-ba00-7`	UUa0f87780-a7fd-46c9-ba00-7c0c0548139e40cf899c-ea08-4217-b03d-cf3db82f1772endReadyForwardf	UU	678a8a33-700e-4677-be42-54bc8e225c3840cf899c-ea08-4217-b03d-cf3db82f1772gatewayWaitingForwardg	UU	e3bea492-c8e6-44f7-b666-08f8d6b6331a40cf899c-ea08-4217-b03d-cf3db82f1772validateWaitingForward�Ue5966227-d	UUe5966227-391f-4a4e-8058-ab911cec03b90ce55144-5f9f-45a4-bd8a-bc0c68d73909approveReadyForward`	UUdf47a819-d1b9-4f47-ac4b-956ebe6dc05b0ce55144-5f9f-45a4-bd8a-bc0c68d73909endReadyForwardf
	UU	3328e837-e4e6-42f8-abb4-f1e0ed9556130ce55144-5f9f-45a4-bd8a-bc0c68d73909gatewayWaitingForwardg	UU	fb3b8909-6b50-4495-b676-437f5148e3b40ce55144-5f9f-45a4-bd8a-bc0c68d73909validateWaitingForward
�2U567acb70-9553-45b9-9949-606fef3a91a5e6b369a`
	UU567acb70-9553-45b9-9949-606fef3a91a5e6b369a2-ff2d-4119-bb6a-27a2c9cf4a99endReadyForwardg		UU	e83be42f-0558-4548-974c-c37956c9e1eee6b369a2-ff2d-4119-bb6a-27a2c9cf4a99validateWaitingForwardRU23c82f22-2da8-490f-a8fe-c1cc949631bfbbf765ea-d945-44c5-b9d0-2195e77744c0end`	UU23c82f22-2da8-490f-a8fe-c1cc949631bfbbf765ea-d945-44c5-b9d0-2195e77744c0endReadyForwardg	UU	e9c8fb65-2f7d-43fb-9fd3-841c75df7965bbf765ea-d945-44c5-b9d0-2195e77744c0validateWaitingForwardd	UU	abac5817-36be-46e2-8543-c9a2e57100e4bbf765ea-d945-44c5-b9d0-2195e77744c0startWaitingForwardf	UU	81229783-070a-47e3-aa99-508e50cf4112edacfa56-567d-41e4-b5d3-9682dc1f449dapproveWaitingForwardg	UU	7e1cdf98-a7c4-4d13-bbeb-5774efa2f253edacfa56-567d-41e4-b5d3-9682dc1f449dvalidateWaitingForward
3��>
�\)g3�

q������]R{�
�
H
���4(U23a54fc6-ac3d-4f2a-9ebf-e32f6a114275(U5963d86c-50b4-429f-89ad-187ea33d37b6(U379b3a0f-162f-4c92-b338-4339a8486579(U8b985f8b-8f29-4b06-8ef9-57f566eb3c9e(Udb1f7448-b33e-4aac-9211-a84e968112a2(U9e441c10-d65f-410b-a821-ccb83fab1df0(Ua29294e9-ba23-4cf4-966d-58404693dc52(U4458ef7f-8d3f-4938-b409-91c3b30dfc64(Ub38ec5dc-dee2-43fb-b030-7a4330ec5456(Ubb88b3c1-7179-4f12-bc89-75abc0c42daa(U18a7a5bd-3896-4b51-9aa0-9d50adf87bc1(U8e46e339-f691-4eb4-bba1-0606c979ea81(Ua0f87780-a7fd-46c9-ba00-7c0c0548139e(U678a8a33-700e-4677-be42-54bc8e225c38(Ue3bea492-c8e6-44f7-b666-08f8d6b6331a(U6f15a073-41b8-4e61-8222-4a9c70f472c4(Ue5966227-391f-4a4e-8058-ab911cec03b9(Udf47a819-d1b9-4f47-ac4b-956ebe6dc05b(U3328e837-e4e6-42f8-abb4-f1e0ed955613
(Ufb3b8909-6b50-4495-b676-437f5148e3b4(U3050c63d-14d6-433e-a94e-8a1a2a35474c(U567acb70-9553-45b9-9949-606fef3a91a5
(Ue83be42f-0558-4548-974c-c37956c9e1ee	(U5cfe0864-3f7d-4841-92b4-07b2a50f69a1(U23c82f22-2da8-490f-a8fe-c1cc949631bf(U924ed0c1-fad0-4304-8eca-b26692ac3e22(Ue9c8fb65-2f7d-43fb-9fd3-841c75df7965(Uabac5817-36be-46e2-8543-c9a2e57100e4(U81229783-070a-47e3-aa99-508e50cf4112(U7e1cdf98-a7c4-4d13-bbeb-5774efa2f253'U	e81ff2c5-fa9e-4b21-88c5-13823d248c0d
3>
�
�
�
q
H
��\3��{R]4�)����g����(U4ab9f3d8-7f00-47c5-bd08-d5efbf30a070(U4ab9f3d8-7f00-47c5-bd08-d5efbf30a070(U4ab9f3d8-7f00-47c5-bd08-d5efbf30a070(U4ab9f3d8-7f00-47c5-bd08-d5efbf30a070(Uc02eded7-f172-4855-9c60-bf5f63734e78(Uc02eded7-f172-4855-9c60-bf5f63734e78(Uc02eded7-f172-4855-9c60-bf5f63734e78(Uc02eded7-f172-4855-9c60-bf5f63734e78(U8f888c62-077a-4b50-a834-098c2dcd9e74(U8f888c62-077a-4b50-a834-098c2dcd9e74(U8f888c62-077a-4b50-a834-098c2dcd9e74(U8f888c62-077a-4b50-a834-098c2dcd9e74(U40cf899c-ea08-4217-b03d-cf3db82f1772(U40cf899c-ea08-4217-b03d-cf3db82f1772(U40cf899c-ea08-4217-b03d-cf3db82f1772(U40cf899c-ea08-4217-b03d-cf3db82f1772(U0ce55144-5f9f-45a4-bd8a-bc0c68d73909(U0ce55144-5f9f-45a4-bd8a-bc0c68d73909(U0ce55144-5f9f-45a4-bd8a-bc0c68d73909
(U0ce55144-5f9f-45a4-bd8a-bc0c68d73909(U0ce55144-5f9f-45a4-bd8a-bc0c68d73909(Ue6b369a2-ff2d-4119-bb6a-27a2c9cf4a99
(Ue6b369a2-ff2d-4119-bb6a-27a2c9cf4a99	(Ue6b369a2-ff2d-4119-bb6a-27a2c9cf4a99(Ubbf765ea-d945-44c5-b9d0-2195e77744c0(Ubbf765ea-d945-44c5-b9d0-2195e77744c0(Ubbf765ea-d945-44c5-b9d0-2195e77744c0(Ubbf765ea-d945-44c5-b9d0-2195e77744c0(Uedacfa56-567d-41e4-b5d3-9682dc1f449d(Uedacfa56-567d-41e4-b5d3-9682dc1f449d'U	edacfa56-567d-41e4-b5d3-9682dc1f449d